[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/24c33485 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24c33485 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/24c33485 Branch: refs/heads/release-1.5 Commit: 24c33485079fb0e60fccf8cf507cb4225cafe8bd Parents: d130f87 Author: Nico Kruber <[email protected]> Authored: Mon Apr 30 15:02:26 2018 +0200 Committer: Stephan Ewen <[email protected]> Committed: Mon Apr 30 23:25:24 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/24c33485/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);
