dmvk commented on a change in pull request #18689:
URL: https://github.com/apache/flink/pull/18689#discussion_r807890572
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/util/BoundedFIFOQueue.java
##########
@@ -56,14 +57,26 @@ public BoundedFIFOQueue(int maxSize) {
* Adds an element to the end of the queue. An element will be removed
from the head of the
* queue if the queue would exceed its maximum size by adding the new
element.
*
- * @param element The element that should be added to the end of the queue.
+ * @param t The element that should be added to the end of the queue.
Review comment:
? :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
