adjust offset

Arize-ai · Jun 6, 2024 · 620b3f5 · 620b3f5
1 parent 57bd4c8
commit 620b3f5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker/client/reader.go b/broker/client/reader.go
@@ -186,7 +186,7 @@ func (r *Reader) Read(p []byte) (n int, err error) {
 				return 0, fmt.Errorf("TransformSignedURL unsupported scheme: %s", fragURL.Scheme)
 			}
 			if r.direct, err = gcs.openWithOffset(r.ctx, fragURL,
-				*r.Response.Fragment, r.Request.Offset); err == nil {
+				*r.Response.Fragment, r.Request.Offset-r.Response.Fragment.Begin); err == nil {
 				n, err = r.Read(p) // Recurse to attempt read against opened |r.direct|.
 			}
 		} else {