[jira] [Created] (FLINK-28221) Savepoint may corrupt file metas by repeat commit

["Jingsong Lee (Jira)" <ji...@apache.org>]

Jingsong Lee created FLINK-28221:
------------------------------------

             Summary: Savepoint may corrupt file metas by repeat commit
                 Key: FLINK-28221
                 URL: https://issues.apache.org/jira/browse/FLINK-28221
             Project: Flink
          Issue Type: Bug
          Components: Table Store
            Reporter: Jingsong Lee
             Fix For: table-store-0.2.0


[https://github.com/apache/flink-table-store/runs/7020439369?check_suite_focus=true]
Error:  Tests run: 3, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 46.953 s <<< FAILURE! - in org.apache.flink.table.store.connector.RescaleBucketITCase 
[32285|https://github.com/apache/flink-table-store/runs/7020439369?check_suite_focus=true#step:4:32286]Error:  testSuspendAndRecoverAfterRescaleOverwrite Time elapsed: 25.545 s <<< ERROR!
{code:java}
Caused by: java.lang.IllegalStateException: Trying to add file {org.apache.flink.table.data.binary.BinaryRowData@9c67b85d, 0, 0, data-4756dfaf-e14e-440e-b211-df2b25f2537a-0.orc} which is already added. Manifest might be corrupted.
32416	at org.apache.flink.util.Preconditions.checkState(Preconditions.java:215)
32417	at org.apache.flink.table.store.file.operation.AbstractFileStoreScan.plan(AbstractFileStoreScan.java:189)
32418	at org.apache.flink.table.store.table.source.TableScan.plan(TableScan.java:99)
32419	at org.apache.flink.table.store.connector.source.FileStoreSource.restoreEnumerator(FileStoreSource.java:117)
32420	at org.apache.flink.table.store.connector.source.FileStoreSource.createEnumerator(FileStoreSource.java:93)
32421	at org.apache.flink.runtime.source.coordinator.SourceCoordinator.start(SourceCoordinator.java:197)
32422	... 33 more {code}



--
This message was sent by Atlassian Jira
(v8.20.7#820007)