LsomeYeah opened a new pull request, #4445: URL: https://github.com/apache/paimon/pull/4445
<!-- Please specify the module before the PR name: [core] ... or [flink] ... --> ### Purpose <!-- Linking this pull request to the issue --> Linked issue: close #xxx <!-- What is the purpose of the change --> A table which is read in streaming read, will not throw exception even if the table is recreated currently. For example, the expected snapshot id is 10001, but the latest snapshot of the recreated table might be null or much less than 10001. This is because when try to get the next snapshot, if the next snapshot is not exists in filesystem and its id is greater than earliest snapshot id, it will be treat as the next snapshot is still in generating progress. This feature adds a check in `NextSnapshotFetcher#getNextSnapshot`. If next expected snapshot id is greater than the latest snapshot id plus one, it will throw an exception. ### Tests <!-- List UT and IT cases to verify this change --> `PrimaryKeyFileStoreTableITCase#testRecreateTableWithException` ### API and Format <!-- Does this change affect API or storage format --> ### Documentation <!-- Does this change introduce a new feature --> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
