com.datastax.driver.core.exceptions.ServerError: на стороне сервера произошла непредвиденная ошибка - PullRequest
Новая
       50

com.datastax.driver.core.exceptions.ServerError: на стороне сервера произошла непредвиденная ошибка

0 голосов
/ 03 октября 2019

Я использую кластер из 9 узлов C * и использую версию datastax-cassandra-java-connector.2.4.1.

Я установил свойства ниже. 

cassandra.concurrent.writes=256
cassandra.output.batch.size.bytes=2048
cassandra.output.batch.grouping.key=partition
cassandra.output.consistency.level=LOCAL_QUORUM
cassandra.output.batch.grouping.buffer.size=3000
cassandra.output.throughput_mb_per_sec=128

cassandra.connection.keep_alive_ms=40000
cassandra.read.timeout_ms=600000
cassandra.concurrent.reads=1024
cassandra.input.consistency.level=LOCAL_QUORUM

Пока я пытаюсьпотреблять меньший набор данных, т.е. 1 миллион строк 

com.datastax.driver.core.exceptions.ServerError: An unexpected error occurred server side on /xyz:9042: com.google.common.util.concurrent.UncheckedExecutionException: com.google.common.util.concurrent.UncheckedExecutionException: java.lang.RuntimeException: org.apache.cassandra.exceptions.ReadTimeoutException: Operation timed out - received only 0 responses.
        at com.datastax.driver.core.Responses$Error.asException(Responses.java:108)

19/10/03 18:15:13 ERROR writer.QueryExecutor: Failed to execute: com.datastax.spark.connector.writer.RichBatchStatement@1ed39373
com.datastax.driver.core.exceptions.TransportException: [/xyz:9042] Connection has been closed

Что здесь не так? и как это исправить?

...