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,

Can you please add the graph properties (configs) and the statements for creating the vertex labels in the graph schema (if any)?

Cheers,    Marc



--
Sincerely,
Umesh Gade

Join janusgraph-users@lists.lfaidata.foundation to automatically receive all group messages.