Arvid Heise created FLINK-36287:
-----------------------------------
Summary: Sink with topologies should not participate in UC
Key: FLINK-36287
URL: https://issues.apache.org/jira/browse/FLINK-36287
Project: Flink
Issue Type: Bug
Reporter: Arvid Heise
Assignee: Arvid Heise
When the sink writer and committer are not chained, it's possible that
committables become part of the channel state. However, then it's possible that
they are not received before notifyCheckpointComplete. Further, the contract of
notifyCheckpointComplete dictates that all side effects need to be committed or
we fail on notifyCheckpointComplete. This contract is essential to final
checkpoints.
We can change by disallowing channel state within sinks.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
