[FLINK-5376] Fix log statement in UnorderedStreamElementQueue This closes #3948.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ed65c253 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ed65c253 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ed65c253 Branch: refs/heads/master Commit: ed65c253478e688fdfbb149a1a75dc01b8537cab Parents: 6ad3d14 Author: zentol <[email protected]> Authored: Fri May 19 14:33:18 2017 +0200 Committer: zentol <[email protected]> Committed: Wed May 24 16:46:03 2017 +0200 ---------------------------------------------------------------------- .../api/operators/async/queue/UnorderedStreamElementQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/ed65c253/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/UnorderedStreamElementQueue.java ---------------------------------------------------------------------- diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/UnorderedStreamElementQueue.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/UnorderedStreamElementQueue.java index c9dc358..e6f71bf 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/UnorderedStreamElementQueue.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/UnorderedStreamElementQueue.java @@ -148,7 +148,7 @@ public class UnorderedStreamElementQueue implements StreamElementQueue { hasCompletedEntries.await(); } - LOG.debug("Peeked head element from ordered stream element queue with filling degree " + + LOG.debug("Peeked head element from unordered stream element queue with filling degree " + "({}/{}).", numberEntries, capacity); return completedQueue.peek();
