question

srinivas3120 avatar image
srinivas3120 asked Erick Ramirez answered

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
Toggle Comment visibility. Current Visibility: Viewable by all users

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

smadhavan avatar image smadhavan ♦ commented ·

@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
Toggle Comment visibility. Current Visibility: Viewable by all users

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