Aleksandr Savonin created FLINK-39854:
-----------------------------------------
Summary: Log JobID in KafkaCommitter
Key: FLINK-39854
URL: https://issues.apache.org/jira/browse/FLINK-39854
Project: Flink
Issue Type: Sub-task
Components: Connectors / Kafka
Reporter: Aleksandr Savonin
We have multiple logs in {{KafkaCommitter}} that will benefit from having
{{JobId}} in the logs.
E.g.
{code:java}
LOG.warn(
"Unable to commit transaction ({}) because its producer is already
fenced."
+ " If this warning appears as part of the recovery of a
checkpoint, it is expected in some cases (e.g., aborted checkpoints in previous
attempt)."
+ " If it's outside of recovery, this means that you either
have a different sink with the same '{}'"
+ " or recovery took longer than '{}' ({}ms). In both cases
this most likely signals data loss,"
+ " please consult the Flink documentation for more details.",
request,
ProducerConfig.TRANSACTIONAL_ID_CONFIG,
ProducerConfig.TRANSACTION_TIMEOUT_CONFIG,
kafkaProducerConfig.getProperty(ProducerConfig.TRANSACTION_TIMEOUT_CONFIG),
e); {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
