[jira] [Created] (FLINK-16525) TwoPhaseCommitSinkFunction subtask logs misleading name

[Shang Yuanchun (Jira)]

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)