rzo1 commented on code in PR #3642:
URL: https://github.com/apache/storm/pull/3642#discussion_r1650933886
##########
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java:
##########
@@ -69,8 +69,9 @@
* destination is currently unavailable.
*/
public class Client extends ConnectionWithStatus implements ISaslClient {
- private static final long PENDING_MESSAGES_FLUSH_TIMEOUT_MS = 600000L;
- private static final long PENDING_MESSAGES_FLUSH_INTERVAL_MS = 1000L;
+ private final long pendingMessagesFlushTimeoutMs ;
+ private final long pendingMessagesFlushIntervalMs;
+ private final double pendingMessagesFlushFactor = 0.0016;
Review Comment:
Fine for me.
--
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: dev-unsubscr...@storm.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
