[CALCITE-6139] Avatica-Go sends the same offset for the FetchRequest

apache · Nov 29, 2023 · 4645f00 · 4645f00
1 parent 1cf62a6
commit 4645f00
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/rows.go b/rows.go
@@ -99,7 +99,7 @@ func (r *rows) Next(dest []driver.Value) error {
 		res, err := r.conn.httpClient.post(context.Background(), &message.FetchRequest{
 			ConnectionId: r.conn.connectionId,
 			StatementId:  r.statementID,
-			Offset:       resultSet.offset,
+			Offset:       resultSet.offset + uint64(len(resultSet.data)),
 			FrameMaxSize: r.conn.config.frameMaxSize,
 		})
 
@@ -130,6 +130,7 @@ func (r *rows) Next(dest []driver.Value) error {
 		resultSet.done = frame.Done
 		resultSet.data = data
 		resultSet.currentRow = 0
+		resultSet.offset = frame.Offset
 
 	}