[
https://issues.apache.org/jira/browse/FLINK-39855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-39855:
-----------------------------------------
Assignee: Aleksandr Savonin
> 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
> Assignee: Aleksandr Savonin
> Priority: Major
>
> 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)
