Я пытаюсь загрузить данные в Cassandra из серии 200000, используя Spring Reactive Cassandra. В большинстве случаев он работает нормально, но иногда я вижу ниже ошибку, приводящую к потере данных при сохранении в Cassandra.
{"thread":"cluster1-nio-worker-0","level":"ERROR","loggerName":"com.google.common.util.concurrent.AbstractFuture","message":"RuntimeException while executing runnable org.springframework.data.cassandra.core.cql.session.DefaultBridgedReactiveSession$$Lambda$1041/1304979740@2b095cbc with executor org.springframework.data.cassandra.core.cql.session.DefaultBridgedReactiveSession$$Lambda$1042/1415755843@74ca8623","thrown":{"commonElementCount":0,"localizedMessage":"org.springframework.data.cassandra.CassandraWriteTimeoutException: ReactiveSessionCallback; CQL [INSERT INTO*******]
Cassandra timeout during SIMPLE write query at consistency LOCAL_ONE (1 replica were required but only 0 acknowledged the write); nested exception is com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout during SIMPLE write query at consistency LOCAL_ONE (1 replica were required but only 0 acknowledged the write)","name":"org.springframework.data.cassandra.CassandraWriteTimeoutException","cause":{"commonElementCount":0,"localizedMessage":"Cassandra timeout during SIMPLE write query at consistency LOCAL_ONE (1 replica were required but only 0 acknowledged the write)","message":"Cassandra timeout during SIMPLE write query at consistency LOCAL_ONE (1 replica were required but only 0 acknowledged the write)","name":"com.datastax.driver.core.exceptions.WriteTimeoutException","cause":{"commonElementCount":0,"localizedMessage":"Cassandra timeout during SIMPLE write query at consistency LOCAL_ONE (1 replica were required but only 0 acknowledged the write)
Пожалуйста, помогите мне, если по какой-либо причине я могу настроить время записи при весенней загрузке или какой-либодругая работа, чтобы избавиться от этой проблемы (я знаю, что размер пакета огромен, и он не проста, чтобы использовать такой большой пакет, но у меня есть ограничение, чтобы завершить эту загрузку данных в ограниченную временную шкалу).