[
https://issues.apache.org/jira/browse/FLINK-38451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-38451:
-----------------------------------
Labels: pull-request-available (was: )
> KafkaCommitter logs ERRORs unnecessarily during cancellation
> ------------------------------------------------------------
>
> Key: FLINK-38451
> URL: https://issues.apache.org/jira/browse/FLINK-38451
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: kafka-5.0.0
> Reporter: Arvid Heise
> Assignee: Arvid Heise
> Priority: Major
> Labels: pull-request-available
>
> When cancelling a job, we may interrupt the KafkaCommitter. This currently
> leads to ERROR log
> {noformat}
> Sep 24, 2025 @ 19:38:13.182 ERROR Transaction
> (CommitRequestImpl{state=RECEIVED, numRetries=0, committable=...,
> subtaskId=3, transactionIdInPool=6, idPoolRangeStartId=5,
> idPoolRangeEndIdExclusive=10, recoveryCounter=1,
> producer=org.apache.flink.connector.kafka.sink.Recyclable@4fc7cb65}})
> encountered error and data has been potentially lost.{noformat}
> However, that exception is expected and not leading to any data loss beyond
> any inconsistencies expected because of cancellation.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
