Skip to content

Commit 4e5a792

Browse files
committed
Resolves #3524: FDBRecordStore.scanTypedRecords skips double records on store using splitLongRecords
1 parent bad6717 commit 4e5a792

File tree

1 file changed

+1
-1
lines changed
  • fdb-record-layer-core/src/main/java/com/apple/foundationdb/record/provider/foundationdb

1 file changed

+1
-1
lines changed

fdb-record-layer-core/src/main/java/com/apple/foundationdb/record/provider/foundationdb/FDBRecordStore.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1322,7 +1322,7 @@ public <M extends Message> RecordCursor<FDBStoredRecord<M>> scanTypedRecords(@No
13221322
.setContext(context).setContinuation(continuation)
13231323
.setLow(low, lowEndpoint)
13241324
.setHigh(high, highEndpoint)
1325-
.setScanProperties(scanProperties.with(ExecuteProperties::clearRowAndTimeLimits).with(ExecuteProperties::clearState))
1325+
.setScanProperties(scanProperties.with(ExecuteProperties::clearRowAndTimeLimits).with(ExecuteProperties::clearSkipAndLimit).with(ExecuteProperties::clearState))
13261326
.build();
13271327
rawRecords = new SplitHelper.KeyValueUnsplitter(context, recordsSubspace, keyValues, useOldVersionFormat(), sizeInfo, scanProperties.isReverse(),
13281328
new CursorLimitManager(context, scanProperties.with(ExecuteProperties::clearReturnedRowLimit)))

0 commit comments

Comments
 (0)