Skip to content

[client] Backport SortMergeReader changelog delete fix to 0.9#3137

Merged
luoyuxia merged 1 commit intoapache:release-0.9from
luoyuxia:backport-776102c-release-0.9
Apr 20, 2026
Merged

[client] Backport SortMergeReader changelog delete fix to 0.9#3137
luoyuxia merged 1 commit intoapache:release-0.9from
luoyuxia:backport-776102c-release-0.9

Conversation

@luoyuxia
Copy link
Copy Markdown
Contributor

Purpose

Linked issue: #3134

Backport the fix from #3135 to release-0.9 so SortMergeReader does not terminate early when changelog delete records match snapshot rows during sort-merge reading.

Brief change log

  • update SnapshotMergedRowIteratorWrapper#hasNext() to skip empty merge results instead of treating them as end-of-input
  • continue advancing until a non-empty merged row is available or the snapshot iterator is actually exhausted
  • add the regression test in SortMergeReaderTest to verify later snapshot rows are still returned after changelog deletes filter earlier rows

Tests

  • ./mvnw -pl fluss-client -am -Drat.skip=true -DfailIfNoTests=false -Dtest=SortMergeReaderTest test

API and Format

No API or storage format changes.

Documentation

No documentation changes are required.

@luoyuxia luoyuxia merged commit 89efcfd into apache:release-0.9 Apr 20, 2026
6 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant