Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5977#discussion_r187639708
--- 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 --
You could probably use only the Operator ID here - the task name does not
add to the uniqueness. Unless the purpose of the task name is "human
readability" in log files or metrics.
---
