Fabian Paul created FLINK-16525:
-----------------------------------
Summary: TwoPhaseCommitSinkFunction subtask logs misleading name
Key: FLINK-16525
URL: https://issues.apache.org/jira/browse/FLINK-16525
Project: Flink
Issue Type: Bug
Components: Runtime / Task
Reporter: Fabian Paul
The current name() function in TwoPhaseCommitSinkFunction tries to describe the
currently running subtask with its class name, the index of the subtask and the
number of parallel subtasks.
Since the starting index of the subtask is 0, and the starting number for the
parallelism is 1, it could lead to the following log message.
{code:java}
15:59:41,448 INFO
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction -
FlinkKafkaProducer 0/1 - checkpoint 1 complete, committing transaction
TransactionHolder{handle=KafkaTransactionState [transactionalId=null,
producerId=-1, epoch=-1], transactionStartTime=1583852371370} from checkpoint 1
{code}
Although only one subtask is running it describes the subtask as 0/1 which
might indicate more than one subtask.
I would suggest incrementing the first number after the class name by 1 to
better indicate how many subtasks are running.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
