From 8c8f1c45face7105c9b60bcfd3f818eea19d42d1 Mon Sep 17 00:00:00 2001
From: Stephan Ewen <sewen@apache.org>
Date: Thu, 28 Jan 2016 16:32:17 +0100
Subject: [PATCH] [hotfix] [streaming] Tasks print subtask in log statements

---
 .../org/apache/flink/streaming/runtime/tasks/StreamTask.java    | 2 +-
 1 file changed, 1 insertion(+), 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
index b91c57049a1..e4b6b6e5d3f 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();
 	}
 
 	/**
-- 
GitLab