You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/02/01 15:57:24 UTC
[3/5] flink git commit: [hotfix] [streaming] Tasks print subtask in
log statements
[hotfix] [streaming] Tasks print subtask in log statements
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c8f1c45
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8c8f1c45
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8c8f1c45
Branch: refs/heads/master
Commit: 8c8f1c45face7105c9b60bcfd3f818eea19d42d1
Parents: ef58cf3
Author: Stephan Ewen <se...@apache.org>
Authored: Thu Jan 28 16:32:17 2016 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Feb 1 14:45:55 2016 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/streaming/runtime/tasks/StreamTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/8c8f1c45/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
index b91c570..e4b6b6e 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
@@ -379,7 +379,7 @@ public abstract class StreamTask<OUT, Operator extends StreamOperator<OUT>>
* @return The name of the task.
*/
public String getName() {
- return getEnvironment().getTaskInfo().getTaskName();
+ return getEnvironment().getTaskInfo().getTaskNameWithSubtasks();
}
/**