Skip to content

Conversation

@wypoon
Copy link
Contributor

@wypoon wypoon commented May 28, 2025

This is a backport of #8980, authored by @cccs-jc.

@github-actions github-actions bot added the spark label May 28, 2025
@wypoon
Copy link
Contributor Author

wypoon commented May 28, 2025

@singhpk234 @huaxingao I discovered that SparkMicroBatchStream in Spark 3.4 was missing this fix when I worked on #13099.
cc @Fokko who merged the original PR.

Snapshot nextValid = nextValidSnapshot(curSnapshot);
if (nextValid == null) {
// nextValid implies all the remaining snapshots should be skipped.
break;
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

In the original, there was a

          shouldContinueReading = false;

before the break, but that was removed as unnecessary by afda8be.

Copy link
Contributor

@singhpk234 singhpk234 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM, thanks @wypoon !

@huaxingao huaxingao merged commit e2de07b into apache:main May 28, 2025
27 checks passed
@huaxingao
Copy link
Contributor

Merged. Thanks @wypoon for the PR! Thanks @singhpk234 for the review!

devendra-nr pushed a commit to devendra-nr/iceberg that referenced this pull request Dec 8, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants