Hi All,
I am trying to create nodes in graph and while reading created node id i am getting below exception:
org.janusgraph.diskstorage.TemporaryBackendException: Temporary failure in storage backend at io.vavr.API$Match$Case0.apply(API.java:3174)
at io.vavr.API$Match.of(API.java:3137)
at org.janusgraph.diskstorage.cql.CQLKeyColumnValueStore.lambda$static$0(CQLKeyColumnValueStore.java:125)
at io.vavr.control.Try.getOrElseThrow(Try.java:671)
at org.janusgraph.diskstorage.cql.CQLKeyColumnValueStore.getSlice(CQLKeyColumnValueStore.java:292)
at org.janusgraph.diskstorage.configuration.backend.KCVSConfiguration$3.call(KCVSConfiguration.java:177)
at org.janusgraph.diskstorage.configuration.backend.KCVSConfiguration$3.call(KCVSConfiguration.java:174)
at org.janusgraph.diskstorage.util.BackendOperation.execute(BackendOperation.java:147)
at org.janusgraph.diskstorage.util.BackendOperation$1.call(BackendOperation.java:161)
at org.janusgraph.diskstorage.util.BackendOperation.executeDirect(BackendOperation.java:68)
... 26 more
Caused by: com.datastax.driver.core.exceptions.ReadTimeoutException: Cassandra timeout during read query at consistency QUORUM (3 responses were required but only 2 replica responded)
I am trying to update janus client to not use QUORUM but LOCAL_ONE. Setting below property but its not working.
JanusGraphFactory.Builder configProps = JanusGraphFactory.build(); configProps.set("storage.cql.read-consistency-level", “LOCAL_ONE”);
In CQLTransaction class i see its getting set by reading value from CustomOption
public CQLTransaction(final BaseTransactionConfig config) {
super(config);
this.readConsistencyLevel = ConsistencyLevel.valueOf(getConfiguration().getCustomOption(READ_CONSISTENCY));
this.writeConsistencyLevel = ConsistencyLevel.valueOf(getConfiguration().getCustomOption(WRITE_CONSISTENCY));
}
I did tied seeing value by using customOption() method of TransactionBuilder but no luck.
GraphTraversalSource g = janusGraph.buildTransaction()
.customOption("storage.cql.read-consistency-level","LOCAL_ONE")
.start().traversal();
Could you please help me to fix it?
Thanks & Regards,
Anjani