Observed driver throwing ClosedConnectionException when it shouldn't?

881 views
Skip to first unread message

Jestin Ma

unread,
Apr 29, 2021, 4:47:02 PM4/29/21
to DataStax Java Driver for Apache Cassandra User Mailing List
When restarting a node in a cluster with replication factor 3, I observed ClosedConnectionException being thrown because there was an error with the Netty IO channel:

Caused by: com.datastax.oss.driver.api.core.connection.ClosedConnectionException: Unexpected error on channel
Caused by: java.io.IOException: Connection reset by peer


The error is understandable since I brought down some node. However, shouldn't the driver retry all coordinators before throwing a AllNodesFailedException containing this exception, as it says so in the documentation?
I believe the error is thrown/interpreted in InFlightHandler. Am I misunderstanding something about why this error is being thrown?

Thanks.
Jestin

Jestin Ma

unread,
Apr 29, 2021, 6:18:52 PM4/29/21
to DataStax Java Driver for Apache Cassandra User Mailing List
Upon more reading, it might be because the retry policy doesn't kick in if the query isn't idempotent.
Reply all
Reply to author
Forward
0 new messages