[FLINK-5376] Fix log statement in UnorderedStreamElementQueue
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/153d73a6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/153d73a6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/153d73a6 Branch: refs/heads/table-retraction Commit: 153d73a6f4ac51dcc02ccdb734d548855f1a1e45 Parents: ae17718 Author: zentol <ches...@apache.org> Authored: Thu Apr 6 13:05:11 2017 +0200 Committer: zentol <ches...@apache.org> Committed: Thu Apr 6 19:35:50 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/153d73a6/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 396dbe8..f2c78f8 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 @@ -123,7 +123,7 @@ public class UnorderedStreamElementQueue implements StreamElementQueue { if (numberEntries < capacity) { addEntry(streamElementQueueEntry); - LOG.debug("Put element into ordered stream element queue. New filling degree " + + LOG.debug("Put element into unordered stream element queue. New filling degree " + "({}/{}).", numberEntries, capacity); return true;
