[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(); } /**
