Hi all,
we were facing ConnectionException for some nodes, connection exception is related to that Cassandra is not connecting to any particular node, is that means the whole cluster is down or any particular node is not available
can I get more inputs on this scenario?
thanks !!
Cassandra version - 3.11.6
Cassandra java Driver - 3.10
2020-07-29 11:33:00:747*[ERROR]*transformreg (2/2)*RequestHandler*onFailure*Unexpected error while querying nosqldb-2.nosqldb.default.svc.cluster.local/x.x.x.x com.datastax.driver.core.exceptions.ConnectionException: [nosqldb-2.nosqldb.default.svc.cluster.local/x.x.x.x:9042] Pool is CLOSING at com.datastax.driver.core.HostConnectionPool.borrowConnection(HostConnectionPool.java:241) at com.datastax.driver.core.RequestHandler$SpeculativeExecution.query(RequestHandler.java:397) at com.datastax.driver.core.RequestHandler$SpeculativeExecution.findNextHostAndQuery(RequestHandler.java:360) at com.datastax.driver.core.RequestHandler.startNewExecution(RequestHandler.java:140) at com.datastax.driver.core.RequestHandler.sendRequest(RequestHandler.java:122) at com.datastax.driver.core.SessionManager.execute(SessionManager.java:697) at com.datastax.driver.core.SessionManager.prepareAsync(SessionManager.java:178) at com.datastax.driver.core.AbstractSession.prepareAsync(AbstractSession.java:104) at com.datastax.driver.mapping.AccessorMapper.prepare(AccessorMapper.java:55) at com.datastax.driver.mapping.MappingManager.getAccessor(MappingManager.java:359) at com.datastax.driver.mapping.MappingManager.createAccessor(MappingManager.java:321) at com.test.cassandra.dao.DetailsDao.fetchDetailsImpl(DetailsDao.java:87) at com.test.cloud.util.DAOUtils.fetchDetails(DAOUtils.java:130) at com.test.cloud.processing.operators.RegistrationRecordConvertor.processElement(RegistrationRecordConvertor.java:94) at com.test.cloud.processing.operators.RegistrationRecordConvertor.processElement(RegistrationRecordConvertor.java:45) at org.apache.flink.streaming.api.operators.KeyedProcessOperator.processElement(KeyedProcessOperator.java:85) at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:202) at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:105) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) at java.lang.Thread.run(Thread.java:748)