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 2018/04/30 21:23:12 UTC
[11/15] flink git commit: [hotfix] [runtime] Fix a debug statement in
StreamTask
[hotfix] [runtime] Fix a debug statement in StreamTask
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ff0622b8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ff0622b8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ff0622b8
Branch: refs/heads/master
Commit: ff0622b8dbd29d445dc7effa6db60f3e7156feee
Parents: 37df3c8
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Mon Apr 30 15:02:26 2018 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Apr 30 21:24:17 2018 +0200
----------------------------------------------------------------------
.../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/ff0622b8/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 182543d..6812871 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
@@ -1191,7 +1191,7 @@ public abstract class StreamTask<OUT, OP extends StreamOperator<OUT>>
@SuppressWarnings("unchecked")
StreamPartitioner<OUT> outputPartitioner = (StreamPartitioner<OUT>) edge.getPartitioner();
- LOG.debug("Using partitioner {} for output {} of task ", outputPartitioner, outputIndex, taskName);
+ LOG.debug("Using partitioner {} for output {} of task {}", outputPartitioner, outputIndex, taskName);
ResultPartitionWriter bufferWriter = environment.getWriter(outputIndex);