Re: Exception while creating vertex with custom vertex id
|
Umesh Gade
Hi Marc, Graph config is as below "configuration" : { "attributes.custom.attribute1.attribute-class" : "java.util.HashMap", "attributes.custom.attribute1.serializer-class" : "com.vrts.itrp.graph.serializers.HashMapSerializer", "attributes.custom.attribute2.attribute-class" : "java.util.HashSet", "attributes.custom.attribute2.serializer-class" : "com.vrts.itrp.graph.serializers.HashSetSerializer", "attributes.custom.attribute3.attribute-class" : "java.util.ArrayList", "attributes.custom.attribute3.serializer-class" : "com.vrts.itrp.graph.serializers.ArrayListSerializer", "attributes.custom.attribute4.attribute-class" : "java.util.LinkedHashMap", "attributes.custom.attribute4.serializer-class" : "com.vrts.itrp.graph.serializers.LinkedHashMapSerializer", "attributes.custom.attribute5.attribute-class" : "java.util.LinkedList", "attributes.custom.attribute5.serializer-class" : "com.vrts.itrp.graph.serializers.LinkedListSerializer", "attributes.custom.attribute6.attribute-class" : "java.util.LinkedHashSet", "attributes.custom.attribute6.serializer-class" : "com.vrts.itrp.graph.serializers.LinkedHashSetSerializer", "query.optimizer-backend-access" : false, "storage.cql.executor-service.enabled" : false, "storage.backend" : "cql", "storage.cql.read-consistency-level" : "LOCAL_QUORUM", "storage.cql.write-consistency-level" : "LOCAL_QUORUM", "storage.read-only" : false, "storage.cql.only-use-local-consistency-for-system-operations" : false, "log.tx.key-consistent" : false, "storage.hostname" : "localhost", "storage.port" : 9042, "storage.cql.keyspace" : "xxx_ks", "storage.cql.local-datacenter" : "dc1", "storage.cql.atomic-batch-mutate" : false, "storage.lock.retries" : 20, "query.fast-property" : false, "query.force-index" : true, "graph.set-vertex-id" : true } Code snippet which creates vertex labels: graph.tx().rollback(); JanusGraphManagement janusMgmt = graph.openManagement(); labels.forEach(l -> { VertexLabel vl = janusMgmt.getVertexLabel(l); if(vl==null) { logger.info("Creating vertex label " + l); janusMgmt.makeVertexLabel(l).make(); } else { logger.info("Vertex label " + l + " already exists"); } }); Further update on issue: - We have continuous retries in our code on exception. This issue was gone when we brought down 3 node cluster to 1 node cluster. - I see below warning logs around the same time. 2022-01-13 15:18:17,042+05:30 WARN com.datastax.oss.driver.internal.core.pool.ChannelPool [JanusGraph Session-admin-7] - [JanusGraph Session|/10.221.187.3:9042] Error while opening new channel (ConnectionInitException: [JanusGraph Session|connecting...] Protocol initialization request, step 1 (STARTUP {CQL_VERSION=3.0.0, DRIVER_NAME=DataStax Java driver for Apache Cassandra(R), DRIVER_VERSION=4.13.0, CLIENT_ID=73988c72-3e8e-426b-b3cd-f6d7893a9f04}): failed to send request (io.netty.channel.StacklessClosedChannelException)) 2022-01-13 15:18:31,174+05:30 WARN com.datastax.oss.driver.internal.core.pool.ChannelPool [JanusGraph Session-admin-7] - [JanusGraph Session|/10.221.187.3:9042] Error while opening new channel (ConnectionInitException: [JanusGraph Session|connecting...] Protocol initialization request, step 1 (STARTUP {CQL_VERSION=3.0.0, DRIVER_NAME=DataStax Java driver for Apache Cassandra(R), DRIVER_VERSION=4.13.0, CLIENT_ID=cb5b14df-85bf-4b90-b48b-be8fdac2404e}): failed to send request (java.nio.channels.NotYetConnectedException))
On Sat, Jan 29, 2022 at 3:51 PM <hadoopmarc@...> wrote: Hi Umesh, --
Sincerely, Umesh Gade
|
|
|