deepak8347
deepak8347
PostsComments
JJanusGraph
Created by deepak8347 on 10/11/2023 in #questions
Changing the Cardinality of a Property
Can I delete the old property completely and create a new property with the correct cardinality with the same name ?
4 replies
JJanusGraph
Created by deepak8347 on 8/22/2023 in #questions
Could not acquire new ID block from storage
Most likely there is an issue in my backend store manager. Please skip this post
8 replies
JJanusGraph
Created by deepak8347 on 8/22/2023 in #questions
Could not acquire new ID block from storage
I increased the block-size but it didn't help. Can you please guide me what all things I can look for
8 replies
JJanusGraph
Created by deepak8347 on 8/22/2023 in #questions
Could not acquire new ID block from storage
8 replies
JJanusGraph
Created by deepak8347 on 8/22/2023 in #questions
Could not acquire new ID block from storage
I am using the following config 
    storage:
      backend: "com.company.org.diskstorage.cassandra.CompanuyCassandraStoreManager"
      company-cassandra:
        read-consistency-level: "ONE"
        write-consistency-level: "ONE"
        atomic-batch-mutate: true # this option is unknown
        batch-statement-size: 100
    cache:
      db-cache: true
      db-cache-time: 2000
      db-cache-size: 0.05
      db-cache-clean-wait: 100
      tx-cache-size: 25000
    query:
      batch: true
      batch-property-prefetch: true
      fast-property: true
      force-index: true
    graph:
      replace-instance-if-exists: true
    ids:
      authority:
        conflict-avoidance-mode: GLOBAL_MANUAL
        conflict-avoidance-tag: 3
        wait-time: 3000
      block-size: 100000
    storage:
      backend: "com.company.org.diskstorage.cassandra.CompanuyCassandraStoreManager"
      company-cassandra:
        read-consistency-level: "ONE"
        write-consistency-level: "ONE"
        atomic-batch-mutate: true # this option is unknown
        batch-statement-size: 100
    cache:
      db-cache: true
      db-cache-time: 2000
      db-cache-size: 0.05
      db-cache-clean-wait: 100
      tx-cache-size: 25000
    query:
      batch: true
      batch-property-prefetch: true
      fast-property: true
      force-index: true
    graph:
      replace-instance-if-exists: true
    ids:
      authority:
        conflict-avoidance-mode: GLOBAL_MANUAL
        conflict-avoidance-tag: 3
        wait-time: 3000
      block-size: 100000
8 replies
JJanusGraph
Created by deepak8347 on 7/25/2023 in #questions
Multiple Graphs with Embedded JanusGraph
Thanks for answering, this helped!!
9 replies
JJanusGraph
Created by deepak8347 on 7/25/2023 in #questions
Multiple Graphs with Embedded JanusGraph
Creating JanusGraphManager this way solved the issue. I thought that we can create two dynamic graphs in the same keyspace, but that is not the case right ?
9 replies
JJanusGraph
Created by deepak8347 on 7/25/2023 in #questions
Multiple Graphs with Embedded JanusGraph
A yaml representation of my janusgraph config is 
  janusGraphConfig:
    storage:
      backend: "com.company.department.diskstorage.cassandra.CompanyCassandraStoreManager"
      batch-loading: true
    query:
      batch: true
      batch-property-prefetch: true
      fast-property: true
      force-index: false
    graph:
      graphname: test-graph
      replace-instance-if-exists: true
    ids:
      block-size: 100000000
  janusGraphConfig:
    storage:
      backend: "com.company.department.diskstorage.cassandra.CompanyCassandraStoreManager"
      batch-loading: true
    query:
      batch: true
      batch-property-prefetch: true
      fast-property: true
      force-index: false
    graph:
      graphname: test-graph
      replace-instance-if-exists: true
    ids:
      block-size: 100000000
9 replies
JJanusGraph
Created by deepak8347 on 7/24/2023 in #questions
Drop an Graph From the Database
Thanks this was super helpful!!
5 replies
JJanusGraph
Created by deepak8347 on 7/10/2023 in #questions
Using Spark with JansuGraph on a Cassandra storage backend
How do we support authentication to the cassandra ? Do we also take password as a parameter ?
10 replies
JJanusGraph
Created by deepak8347 on 7/10/2023 in #questions
Using Spark with JansuGraph on a Cassandra storage backend
Thanks @boxuanli for helping !! 1. I changed the backend to cql, but still getting the same issue. Do I need some additional configurations ? 
    janusgraphmr:
      ioformat:
        conf:
          storage:
            backend: cql
    janusgraphmr:
      ioformat:
        conf:
          storage:
            backend: cql
2. The CompanyCassandraStoreManager allows us to create connection with our Cassandra. Our OLTP janusgraph is working with this storage backend. It contains the details regarding how we are going to connect with Cassandra (especially it contains the Cassandra Managed which is used to manage Cassandra client along with taking care of Authentication). 
public class CompanyCassandraStoreManager extends DistributedStoreManager implements KeyColumnValueStoreManager {
    static final String CONSISTENCY_QUORUM = "QUORUM";
    static final String EDGESTORE_LOCK = "edgestore_lock_";
    .......
    static final String TXLOG = "txlog";
    private final CassandraManaged cassandraManaged;
public class CompanyCassandraStoreManager extends DistributedStoreManager implements KeyColumnValueStoreManager {
    static final String CONSISTENCY_QUORUM = "QUORUM";
    static final String EDGESTORE_LOCK = "edgestore_lock_";
    .......
    static final String TXLOG = "txlog";
    private final CassandraManaged cassandraManaged;
Can I not use this storage backend and I should specify the hostname and port as shown in the example(https://docs.janusgraph.org/advanced-topics/hadoop/) ?
10 replies
JJanusGraph
Created by deepak8347 on 7/10/2023 in #questions
Using Spark with JansuGraph on a Cassandra storage backend
The current error message is 
Caused by: java.lang.UnsupportedOperationException: You must set the initial output address to a Cassandra node with setInputInitialAddress
        at org.apache.cassandra.hadoop.cql3.CqlInputFormat.validateConfiguration(CqlInputFormat.java:112)
        at org.apache.cassandra.hadoop.cql3.CqlInputFormat.getSplits(CqlInputFormat.java:121)
        at org.janusgraph.hadoop.formats.cql.CqlBinaryInputFormat.getSplits(CqlBinaryInputFormat.java:53)
        at org.janusgraph.hadoop.formats.util.HadoopInputFormat.getSplits(HadoopInputFormat.java:55)
        at org.apache.tinkerpop.gremlin.hadoop.structure.io.HadoopElementIterator.<init>(HadoopElementIterator.java:65)
Caused by: java.lang.UnsupportedOperationException: You must set the initial output address to a Cassandra node with setInputInitialAddress
        at org.apache.cassandra.hadoop.cql3.CqlInputFormat.validateConfiguration(CqlInputFormat.java:112)
        at org.apache.cassandra.hadoop.cql3.CqlInputFormat.getSplits(CqlInputFormat.java:121)
        at org.janusgraph.hadoop.formats.cql.CqlBinaryInputFormat.getSplits(CqlBinaryInputFormat.java:53)
        at org.janusgraph.hadoop.formats.util.HadoopInputFormat.getSplits(HadoopInputFormat.java:55)
        at org.apache.tinkerpop.gremlin.hadoop.structure.io.HadoopElementIterator.<init>(HadoopElementIterator.java:65)
I have added the complete stack trace in the file
10 replies