Jingsong Lee created FLINK-31195:
------------------------------------
Summary: FullChangelogStoreSinkWrite bucket writer conflicts with
rescale
Key: FLINK-31195
URL: https://issues.apache.org/jira/browse/FLINK-31195
Project: Flink
Issue Type: Bug
Components: Table Store
Reporter: Jingsong Lee
Fix For: table-store-0.4.0
At present, this operator relies on ListState, Flink distributes data according
to round-robin when rescaling, which may be different from the distribution
rules of our bucket after rescaling.
We need to change the mode of UnionListState, broadcast to each node, and
finally decide whether it belongs to the task.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
