Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187645022
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
---
@@ -837,7 +837,7 @@ public void
initializeState(FunctionInitializationContext context) throws Except
nextTransactionalIdHintState =
context.getOperatorStateStore().getUnionListState(
NEXT_TRANSACTIONAL_ID_HINT_DESCRIPTOR);
transactionalIdsGenerator = new TransactionalIdsGenerator(
- getRuntimeContext().getTaskName(),
+ getRuntimeContext().getTaskName() + "-" +
getRuntimeContext().getOperatorUniqueID(),
--- End diff --
Yes, I wanted to keep the task name for the readability reasons.
---
