storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From s...@apache.org
Subject [5/7] storm git commit: MINOR: Correct comment about overflow limiting in JCQueue. Setting overflow limit to 0 disables limiting, does not disable overflow
Date Sat, 05 Jan 2019 15:02:55 GMT
MINOR: Correct comment about overflow limiting in JCQueue. Setting overflow limit to 0 disables
limiting, does not disable overflow


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7d14d02e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7d14d02e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7d14d02e

Branch: refs/heads/master
Commit: 7d14d02ed309fd724b3ecccf2a75a65b0359eee6
Parents: cf00a53
Author: Stig Rohde Døssing <srdo@apache.org>
Authored: Fri Dec 21 18:51:17 2018 +0100
Committer: Stig Rohde Døssing <srdo@apache.org>
Committed: Fri Dec 21 18:51:17 2018 +0100

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


http://git-wip-us.apache.org/repos/asf/storm/blob/7d14d02e/storm-client/src/jvm/org/apache/storm/utils/JCQueue.java
----------------------------------------------------------------------
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 08e26f7..6f78ee0 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.


Mime
View raw message