[FLINK-5376] Fix log statement in UnorderedStreamElementQueue

153d73a6 · zentol · ae17718f · 153d73a6
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/UnorderedStreamElementQueue.java ...pi/operators/async/queue/UnorderedStreamElementQueue.java +1 -1

未找到文件。
--- 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;