Github user dineshjoshi commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/253#discussion_r215735492
--- Diff: src/java/org/apache/cassandra/streaming/async/NettyStreamingMessageSender.java
---
@@ -393,6 +393,18 @@ private Channel getOrCreateChannel()
}
}
+ private void onError(Throwable t)
+ {
+ try
+ {
+ session.onError(t).get(5, TimeUnit.MINUTES);
--- End diff --
Why do we have a 5 minute timeout? We should pull this out as a constant.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: pr-unsubscribe@cassandra.apache.org
For additional commands, e-mail: pr-help@cassandra.apache.org
|