带有connectioninitexception的java警告消息的spark cassandra连接器

kmpatx3s  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(267)

当我运行cassandra作业时,我不断收到spark项目的警告消息

WARN ChannelPool: [s0|/172.17.0.3: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.5.0, CLIENT_ID=ef6bf95c-e93f-4f59-860a-829ae07e80cb, APPLICATION_NAME=Spark-Cassandra-Connector-local-1593841648738}): failed to send request (java.nio.channels.ClosedChannelException))

我没有看到任何数据丢失,但我也不知道为什么会发生这种情况
我有3节点Cassandradocker在我的电脑上运行
cassandra版本:-3.11.6 spark版本:-2.4.6 java:jdk8
键空间信息:

keyspace_name    durable_writes        replication
mykeyspace          true           {class=org.apache.cassandra.locator.NetworkTopologyStrategy, datacenter1=1, datacenter2=1}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题