[hotfix] [streaming] Tasks print subtask in log statements

scsha · Feb 1, 2016 · 8c8f1c4 · 8c8f1c4
1 parent ef58cf3
commit 8c8f1c4
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -379,7 +379,7 @@ protected void finalize() throws Throwable {
 	 * @return The name of the task.
 	 */
 	public String getName() {
-		return getEnvironment().getTaskInfo().getTaskName();
+		return getEnvironment().getTaskInfo().getTaskNameWithSubtasks();
 	}
 
 	/**