You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2020/03/11 07:04:15 UTC
[flink] branch master updated: [FLINK-16525][task] Increment
subtask id by 1 to display subtask name
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 642f096 [FLINK-16525][task] Increment subtask id by 1 to display subtask name
642f096 is described below
commit 642f096163798962d1e9412c195985aee13a82fc
Author: Fabian Paul <fa...@ververica.com>
AuthorDate: Tue Mar 10 16:51:09 2020 +0100
[FLINK-16525][task] Increment subtask id by 1 to display subtask name
---
.../flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
index 25e1d4a..6a42fb9 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
@@ -484,7 +484,7 @@ public abstract class TwoPhaseCommitSinkFunction<IN, TXN, CONTEXT>
return String.format(
"%s %s/%s",
this.getClass().getSimpleName(),
- getRuntimeContext().getIndexOfThisSubtask(),
+ getRuntimeContext().getIndexOfThisSubtask() + 1,
getRuntimeContext().getNumberOfParallelSubtasks());
}