I had two queries run on same row in parallel (that's a use-case). While Batch
Query 2 completed successfully, query 1 failed with exception.
Following are driver logs and sequence of log events.
QUERY 1: STARTED
2019-04-30T13:14:50.858+0000 CQL update "EACH_QUORUM" "UPDATE dir SET
bid='value' WHERE repoid='06A7490B5CBFA1DE0A494027' IF EXISTS;"
QUERY 2: STARTED
2019-04-30T13:14:51.161+0000 CQL BEGIN BATCH
2019-04-30T13:14:51.161+0000 CQL batch-update "06A7490B5CBFA1DE0A494027"
2019-04-30T13:14:51.161+0000 CQL batch-delete "06A7490B5CBFA1DE0A494027"
2019-04-30T13:14:51.161+0000 CQL APPLY BATCH
2019-04-30T13:14:51.165+0000 Cassandra delete directory call completed
successfully for "06A7490B5CBFA1DE0A494027"
QUERY 2: COMPLETED - WITH SUCCESS
QUERY 1: FAILED
2019-04-30T13:14:52.311+0000 CQL
"org.springframework.cassandra.support.exception.CassandraWriteTimeoutException"
"Cassandra timeout during write query at consistency SERIAL (5 replica were
required but only 0 acknowledged the write); nested exception is
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout
during write query at consistency SERIAL (5 replica were required but only 0
acknowledged the write)"
org.springframework.cassandra.support.exception.CassandraWriteTimeoutException:
Cassandra timeout during write query at consistency SERIAL (5 replica were
required but only 0 acknowledged the write); nested exception is
com.datastax.driver.core.exceptions.WriteTimeoutException: Cassandra timeout
during write query at consistency SERIAL (5 replica were required but only 0
acknowledged the write)
at
org.springframework.cassandra.support.CassandraExceptionTranslator.translateExceptionIfPossible(CassandraExceptionTranslator.java:95)
~[spring-cql-1.5.18.RELEASE.jar!/:?]
at
org.springframework.cassandra.core.CqlTemplate.potentiallyConvertRuntimeException(CqlTemplate.java:946)
~[spring-cql-1.5.18.RELEASE.jar!/:?]
at
org.springframework.cassandra.core.CqlTemplate.translateExceptionIfPossible(CqlTemplate.java:930)
~[spring-cql-1.5.18.RELEASE.jar!/:?]
What could have caused this exception ?
How to resolve or handle such situation ?
Thanks,
Bhavesh
