[ https://issues.apache.org/jira/browse/FLINK-31195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee closed FLINK-31195. -------------------------------- Resolution: Fixed > 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 > Priority: Major > 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)