Aleksandr Savonin created FLINK-39855:
-----------------------------------------
Summary: Include JobID in the backchannel key (cross-job
robustness)
Key: FLINK-39855
URL: https://issues.apache.org/jira/browse/FLINK-39855
Project: Flink
Issue Type: Sub-task
Components: Connectors / Kafka
Reporter: Aleksandr Savonin
The writer-committer backchannel is matched in a static JVM-wide singleton map
keyed only by (subtaskId, attemptNumber, transactionalIdPrefix).
Today this relies on the prefix being globally unique to avoid cross-job
collisions in a session/standalone TaskManager sharing one JVM. Adding JobID to
the key makes it robust even if two jobs accidentally reuse a prefix.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
