Jingsong Lee created FLINK-29295:
------------------------------------
Summary: Clear RecordWriter slower to avoid causing frequent
compaction conflicts
Key: FLINK-29295
URL: https://issues.apache.org/jira/browse/FLINK-29295
Project: Flink
Issue Type: Bug
Components: Table Store
Reporter: Jingsong Lee
Assignee: Jingsong Lee
Fix For: table-store-0.3.0, table-store-0.2.1
In AbstractTableWrite, the Writer is cleaned up as soon as no new files are
generated, which may lead to the changes generated after the compaction have
not been committed, but the new data from the next checkpoint comes to create a
new writer, which conflicts with the changes generated in the next round of
checkpoint and the previous round, resulting in an exception.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
