You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/04/19 09:12:44 UTC
[3/4] flink git commit: [hotfix] Generated OperatorSubtaskDescription
string should start counting from 1 for index 0
[hotfix] Generated OperatorSubtaskDescription string should start counting from 1 for index 0
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1bfe87f1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1bfe87f1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1bfe87f1
Branch: refs/heads/master
Commit: 1bfe87f12274a96e517f6229ddbc01622cfb50a0
Parents: a455d6a
Author: Stefan Richter <s....@data-artisans.com>
Authored: Wed Apr 18 18:24:28 2018 +0200
Committer: Stefan Richter <s....@data-artisans.com>
Committed: Thu Apr 19 11:12:22 2018 +0200
----------------------------------------------------------------------
.../apache/flink/runtime/util/OperatorSubtaskDescriptionText.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/1bfe87f1/flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java b/flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java
index 65b3714..ec2e571 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java
@@ -37,7 +37,7 @@ public class OperatorSubtaskDescriptionText {
this.description = operatorClass +
"_" + operatorId +
- "_(" + subtaskIndex + "/" + numberOfTasks + ")";
+ "_(" + (1 + subtaskIndex) + "/" + numberOfTasks + ")";
}
@Override