Bringing together the Apache Cassandra experts from the community and DataStax.

Want to learn? Have a question? Want to share your expertise? You are in the right place!

Not sure where to begin? Getting Started

 

question

srinivas3120 avatar image
srinivas3120 asked ·

ControlConnection: Error connecting to Node

I am having a hard time understanding the following errors. Why do we get these errors?
dependencies
scala 2.12, spark 3.0.1, spark-Cassandra-Connector 3.0.0, java driver core 4.7.2

your help is highly appreciated. thank you


[s0-admin-1] control.ControlConnection: [s0] Error connecting to Node(endPoint=/192.168.56.53:9042, hostId=a12df1dd-ce3e-4c24-aa89-ec2264f98413, hashCode=139723f6), trying next node (ConnectionInitException: [s0|control|connecting...] Protocol initialization request, step 1 (STARTUP {CQL_VERSION=3.0.0, DRIVER_NAME=DataStax Java driver for Apache Cassandra(R), DRIVER_VERSION=4.7.2, CLIENT_ID=469d1425-2998-4026-86eb-673edd11a9d5, APPLICATION_NAME=Spark-Cassandra-Connector-local-1605124076061}): failed to send request (java.nio.channels.NotYetConnectedException))

[s0-admin-0] pool.ChannelPool: [s0|/192.168.41.0:9042]  Error while opening new channel (ConnectionInitException: [s0|connecting...] Protocol initialization request, step 1 (STARTUP {CQL_VERSION=3.0.0, DRIVER_NAME=DataStax Java driver for Apache Cassandra(R), DRIVER_VERSION=4.7.2, CLIENT_ID=469d1425-2998-4026-86eb-673edd11a9d5, APPLICATION_NAME=Spark-Cassandra-Connector-local-1605124076061}): failed to send request (java.nio.channels.NotYetConnectedException))

[s0-admin-1] pool.ChannelPool: [s0|/192.168.56.53:9042]  Error while opening new channel (ConnectionInitException: [s0|connecting...] Protocol initialization request, step 1 (STARTUP {CQL_VERSION=3.0.0, DRIVER_NAME=DataStax Java driver for Apache Cassandra(R), DRIVER_VERSION=4.7.2, CLIENT_ID=469d1425-2998-4026-86eb-673edd11a9d5, APPLICATION_NAME=Spark-Cassandra-Connector-local-1605124076061}): failed to send request (java.nio.channels.NotYetConnectedException)

[s0-admin-0] pool.ChannelPool: [s0|/192.168.41.0:9042]  Error while opening new channel (ConnectionInitException: [s0|connecting...] Protocol initialization request, step 1 (STARTUP {CQL_VERSION=3.0.0, DRIVER_NAME=DataStax Java driver for Apache Cassandra(R), DRIVER_VERSION=4.7.2, CLIENT_ID=469d1425-2998-4026-86eb-673edd11a9d5, APPLICATION_NAME=Spark-Cassandra-Connector-local-1605124076061}): failed to send request (java.nio.channels.NotYetConnectedException))
spark-cassandra-connector
1 comment
10 |1000 characters needed characters left characters exceeded

Up to 8 attachments (including images) can be used with a maximum of 1.0 MiB each and 10.0 MiB total.

@srinivas3120, have you made sure the C* cluster nodes 192.168.56.53 and 192.168.41.0 are indeed up & reachable at the native transport port of 9042?

0 Likes 0 · ·

1 Answer

Erick Ramirez avatar image
Erick Ramirez answered ·

As the error suggests, the driver embedded in the Spark connector cannot connect to any nodes.

The most common cause of this error is network connectivity. For example, the connector doesn't have a route to get to any nodes to setup the control connection. Or client-to-node encryption is enabled on your cluster but you haven't configured the connector with the encryption options. Cheers!

Share
10 |1000 characters needed characters left characters exceeded

Up to 8 attachments (including images) can be used with a maximum of 1.0 MiB each and 10.0 MiB total.