From 7d14d02ed309fd724b3ecccf2a75a65b0359eee6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Stig=20Rohde=20D=C3=B8ssing?= <srdo@apache.org>
Date: Fri, 21 Dec 2018 18:51:17 +0100
Subject: [PATCH] MINOR: Correct comment about overflow limiting in JCQueue.
 Setting overflow limit to 0 disables limiting, does not disable overflow

---
 storm-client/src/jvm/org/apache/storm/utils/JCQueue.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/storm-client/src/jvm/org/apache/storm/utils/JCQueue.java b/storm-client/src/jvm/org/apache/storm/utils/JCQueue.java
index 08e26f77bbd..6f78ee0df7e 100644
--- a/storm-client/src/jvm/org/apache/storm/utils/JCQueue.java
+++ b/storm-client/src/jvm/org/apache/storm/utils/JCQueue.java
@@ -51,7 +51,7 @@ public class JCQueue implements IStatefulObject, Closeable {
     private final MpscArrayQueue<Object> recvQueue;
     // only holds msgs from other workers (via WorkerTransfer), when recvQueue is full
     private final MpscUnboundedArrayQueue<Object> overflowQ;
-    private final int overflowLimit; // ensures... overflowCount <= overflowLimit. if set to 0, disables overflow.
+    private final int overflowLimit; // ensures... overflowCount <= overflowLimit. if set to 0, disables overflow limiting.
     private final int producerBatchSz;
     private final DirectInserter directInserter = new DirectInserter(this);
     private final ThreadLocal<BatchInserter> thdLocalBatcher = new ThreadLocal<BatchInserter>(); // ensure 1 instance per producer thd.