Date   

Re: Count Query Optimization

hadoopmarc@...
 

Hi all,

I also thought about the vertex centrex index first, but I am afraid that the VCI can only help to filter the edges to follow, but it does not help in counting the edges. A better way to investigate is to leave out the final inV() step. So, e.g. you can count the number of distinct v2 id's with:
g.V().has('property1', 'A').outE().has('property1','E').id().map{it.get().getOutVertexId()}.dedup().count()

Note that E().id() returns RelationIdentifier() objects that contain both the edge id, the inVertexId and the OutVertexId. This should diminish the number of storage backend calls.

Best wishes,    Marc


Re: Count Query Optimization

AMIYA KUMAR SAHOO
 

Hi Vinayak,

For query 1.

What is the degree centrality of vertex having property A. How much percentage satisfy out edge having property E. If it is small, VCI will help to increase speed for this traversal.

You can give it a try to below query, not sure if it will speed up.

g.V().has('property1', 'A').
    outE().has('property1','E').
    inV().has('property1', 'B').
    dedup().by(path()).
    count()



On Fri, 12 Mar 2021, 13:30 Vinayak Bali, <vinayakbali16@...> wrote:
Hi All,

The schema consists of A, B as nodes, and E as an edge with some other nodes and edges. 
A: 183468
B: 437317
E: 186513

Query:  g.V().has('property1', 'A').as('v1').outE().has('property1','E').as('e').inV().has('property1', 'B').as('v2').select('v1','e','v2').dedup().count()
Output: 200166
Time Taken: 1min

Query: g.V().has('property1', 'A').aggregate('v').outE().has('property1','E').aggregate('e').inV().has('property1', 'B').aggregate('v').select('v').dedup().as('vetexCount').select('e').dedup().as('edgeCount').select('vetexCount','edgeCount').by(unfold().count())
Output: ==>[vetexCount:383633,edgeCount:200166]
Time: 3.5 mins
Property1 is the index.
How can I optimize the queries because minutes of time for count query is not optimal. Please suggest different approaches. 

Thanks & Regards,
Vinayak


Threads are unresponsive for some time after a particular amount of data transfer(119MB)

Vinayak Bali
 

Hi All,

We are connecting to janusgraph using java. A cluster connection with the gremlin driver is used for the connectivity. At the start, we were getting out of memory error, but tweaking some changes in gremlin-server.yaml resolved the issue.
The issue raised on StackOverflow: 


Changes made in gremlin-server.yaml:
writeBufferLowWaterMark: 9500000
writeBufferHighWaterMark: 10000000
Every query gets stuck at 119 MB for some time i.e approx 5 mins and again starts working.
Attaching a screenshot of the error.

Gremlin server configurations:

maxInitialLineLength: 4096
maxHeaderSize: 8192
maxChunkSize: 16384
maxContentLength: 2000000000
maxAccumulationBufferComponents: 1024
resultIterationBatchSize: 128
writeBufferLowWaterMark: 9500000
writeBufferHighWaterMark: 10000000
threadPoolWorker: 30
gremlinPool: 0

How can the issue be solved ??

Thanks & Regards,
Vinayak


Re: Multiple vertices generated for the same index value and vertex properties missing with RF3

hadoopmarc@...
 

Hi Saurabh,

The workaround you found has implications for performance. So, if you can describe how  to reproduce the issue, you can make an issue for it on https://github.com/JanusGraph/janusgraph/issues
This might easily be a scenario that is not covered by the current janusgraph tests.

I see that "id" is indeed a property key in the schema. I assume your input data already had this "id" property and this was not generated by janusgraph. In the former case does replacing "id" by "user_id" make any difference (this will make your queries more readable anyway)?

Best wishes,    Marc


Count Query Optimization

Vinayak Bali
 

Hi All,

The schema consists of A, B as nodes, and E as an edge with some other nodes and edges. 
A: 183468
B: 437317
E: 186513

Query:  g.V().has('property1', 'A').as('v1').outE().has('property1','E').as('e').inV().has('property1', 'B').as('v2').select('v1','e','v2').dedup().count()
Output: 200166
Time Taken: 1min

Query: g.V().has('property1', 'A').aggregate('v').outE().has('property1','E').aggregate('e').inV().has('property1', 'B').aggregate('v').select('v').dedup().as('vetexCount').select('e').dedup().as('edgeCount').select('vetexCount','edgeCount').by(unfold().count())
Output: ==>[vetexCount:383633,edgeCount:200166]
Time: 3.5 mins
Property1 is the index.
How can I optimize the queries because minutes of time for count query is not optimal. Please suggest different approaches. 

Thanks & Regards,
Vinayak


Re: Caused by: org.janusgraph.core.JanusGraphException: A JanusGraph graph with the same instance id [0a000439355-0b2b58ca5c222] is already open. Might required forced shutdown.

hadoopmarc@...
 

Hi Srinivas,

If you read https://docs.janusgraph.org/basics/configured-graph-factory/#configurationmanagementgraph you will see that the configured graph configs and their graphnames are stored in the system tables. Therefore, I I suspect it has to do with the names of graphs in the system table and the graphs section of your yaml config file. So, we will just have to try a few things:
  1. what happens if you leave out the line ¨graph: /etc/opt/janusgraph/janusgraph.properties,¨ ?
  2. what happens if you replace graph: with uniquename: in the graphs section?
  3. does the /etc/opt/janusgraph/janusgraph.properties contain a line with graph.graphname=uniquename ?
Best wishes,    Marc


Re: JMX authentication for cassandra

hadoopmarc@...
 


Re: JMX authentication for cassandra

Vinayak Bali
 

Hi Marc,

We get the same error.

On Thu, 11 Mar 2021, 4:44 pm , <hadoopmarc@...> wrote:
Hi Vinayak,

What happend after you tried:

LOCAL_JMX=no
if [ "$LOCAL_JMX" = "yes" ]; then
  JVM_OPTS="$JVM_OPTS -Dcassandra.jmx.local.port=$JMX_PORT -XX:+DisableExplicitGC"
else
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.port=$JMX_PORT"
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.rmi.port=$JMX_PORT"
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.ssl=false"
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.authenticate=true"
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.password.file=/etc/cassandra/jmxremote.password"
#  JVM_OPTS="$JVM_OPTS -Djavax.net.ssl.keyStore=/path/to/keystore"
#  JVM_OPTS="$JVM_OPTS -Djavax.net.ssl.keyStorePassword=<keystore-password>"
#  JVM_OPTS="$JVM_OPTS -Djavax.net.ssl.trustStore=/path/to/truststore"
#  JVM_OPTS="$JVM_OPTS -Djavax.net.ssl.trustStorePassword=<truststore-password>"
#  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.ssl.need.client.auth=true"
#  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.registry.ssl=true"
#  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.ssl.enabled.protocols=<enabled-protocols>"
#  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.ssl.enabled.cipher.suites=<enabled-cipher-suites>"
fi

Best wishes,    Marc


Re: Caused by: org.janusgraph.core.JanusGraphException: A JanusGraph graph with the same instance id [0a000439355-0b2b58ca5c222] is already open. Might required forced shutdown.

Real Life Adventure
 

Hi Marc,
          Thanks for the Response.
          Yes.I get this error while restarting gremlin server.
          Please find attached  gremlin server yaml file for further details.

Thanks,
Srinivas.


Re: JMX authentication for cassandra

hadoopmarc@...
 

Hi Vinayak,

What happend after you tried:

LOCAL_JMX=no
if [ "$LOCAL_JMX" = "yes" ]; then
  JVM_OPTS="$JVM_OPTS -Dcassandra.jmx.local.port=$JMX_PORT -XX:+DisableExplicitGC"
else
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.port=$JMX_PORT"
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.rmi.port=$JMX_PORT"
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.ssl=false"
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.authenticate=true"
  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.password.file=/etc/cassandra/jmxremote.password"
#  JVM_OPTS="$JVM_OPTS -Djavax.net.ssl.keyStore=/path/to/keystore"
#  JVM_OPTS="$JVM_OPTS -Djavax.net.ssl.keyStorePassword=<keystore-password>"
#  JVM_OPTS="$JVM_OPTS -Djavax.net.ssl.trustStore=/path/to/truststore"
#  JVM_OPTS="$JVM_OPTS -Djavax.net.ssl.trustStorePassword=<truststore-password>"
#  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.ssl.need.client.auth=true"
#  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.registry.ssl=true"
#  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.ssl.enabled.protocols=<enabled-protocols>"
#  JVM_OPTS="$JVM_OPTS -Dcom.sun.management.jmxremote.ssl.enabled.cipher.suites=<enabled-cipher-suites>"
fi

Best wishes,    Marc


Re: Caused by: org.janusgraph.core.JanusGraphException: A JanusGraph graph with the same instance id [0a000439355-0b2b58ca5c222] is already open. Might required forced shutdown.

hadoopmarc@...
 

Hi Srinivas,

Do I understand right that you get this error on restarting of gremlin server?
How does the yaml config file for gremlin server look like?

Best wishes,    Marc


Re: Script16.groovy: 2: unable to resolve class StandardJanusGraph

hadoopmarc@...
 

Hi Vinayak,

If I understand it right (did not test it), you have to use two gremlin consoles:

  1. Use one gremlin console to connect to your server and use ConfiguredGraphFactory. This will manage which graphs are available to to other gremlin console instances.
  2. Use the second gremlin console to connect to the graph that you activated in the first console. In the second console you can use a sessioned remote connection to do any imports you need to run your script remotely.
Best wishes,    Marc


Caused by: org.janusgraph.core.JanusGraphException: A JanusGraph graph with the same instance id [0a000439355-0b2b58ca5c222] is already open. Might required forced shutdown.

Real Life Adventure
 

Hi,

getting janusgraph same instance  issue even if i set graph.replace-instance-if-exists=true .please respond to below issue.any help appreciated.

graph.replace-instance-if-exists=true
jnausgraph version 0.5.2
 
 
- Version:0.5.2
- Storage Backend:cql
- Mixed Index Backend:elasticsearch
 
```
10689 [main] ERROR org.apache.tinkerpop.gremlin.server.util.ServerGremlinExecutor  - Could not invoke constructor on class org.janusgraph.graphdb.management.JanusGraphManager (defined by the 'graphManager' setting) with one argument of class Settings
 
 
Exception in thread "main" java.lang.RuntimeException: java.lang.reflect.InvocationTargetException
 
 
at org.apache.tinkerpop.gremlin.server.util.ServerGremlinExecutor.<init>(ServerGremlinExecutor.java:91)
 
 
at org.apache.tinkerpop.gremlin.server.GremlinServer.<init>(GremlinServer.java:122)
 
 
at org.apache.tinkerpop.gremlin.server.GremlinServer.<init>(GremlinServer.java:86)
 
 
at org.apache.tinkerpop.gremlin.server.GremlinServer.main(GremlinServer.java:345)
 
 
Caused by: java.lang.reflect.InvocationTargetException
 
 
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
 
 
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
 
 
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
 
 
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
 
 
at org.apache.tinkerpop.gremlin.server.util.ServerGremlinExecutor.<init>(ServerGremlinExecutor.java:80)
 
 
... 3 more
 
 
Caused by: org.janusgraph.core.JanusGraphException: A JanusGraph graph with the same instance id [0a000439355-0b2b58ca5c222] is already open. Might required forced shutdown.
 
 
at org.janusgraph.graphdb.database.StandardJanusGraph.<init>(StandardJanusGraph.java:173)
 
 
at org.janusgraph.core.JanusGraphFactory.lambda$open$0(JanusGraphFactory.java:150)
 
 
at org.janusgraph.graphdb.management.JanusGraphManager.openGraph(JanusGraphManager.java:243)
 
 
at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:150)
 
 
at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:100)
 
 
at org.janusgraph.graphdb.management.JanusGraphManager.lambda$new$0(JanusGraphManager.java:75)
 
 
at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)
 
 
at org.janusgraph.graphdb.management.JanusGraphManager.<init>(JanusGraphManager.java:74)
 
 
... 8 more
```

Thanks,
Srinivas


Re: Not able to reindex with bigtable as backend

owner.mad.epa@...
 

Reindex process may stuck on ghost vertices, see https://github.com/JanusGraph/janusgraph/issues/1750

Try to remove ghost vertices by GhostVertexRemover

JanusGraphManagement.IndexJobFuture ghostRemover =
graph.getBackend().buildEdgeScanJob()
.setJob(new GhostVertexRemover(graph))
.execute();
try {
logger.info("GhostVertexRemover statistics: {},{},{}",
ghostRemover.get().getCustom(REMOVED_VERTEX_COUNT),
ghostRemover.get().getCustom(REMOVED_RELATION_COUNT),
ghostRemover.get().getCustom(SKIPPED_GHOST_LIMIT_COUNT));
} catch (InterruptedException | ExecutionException e) {
throw new RuntimeException(e);
}


Re: JMX authentication for cassandra

Vinayak Bali
 

Hi Marc,

How can I enable JMX authentication for the Cassandra daemon ?? 

Thanks & Regards,
Vinayak

On Tue, Mar 9, 2021 at 10:01 PM <hadoopmarc@...> wrote:
Hi Vinayak,

Please review the change you made in the cassandra-env.sh, it does not make sense.  I do not know about JMX settings for Cassandra either, but the cassandra-env.sh is written such that you do not have to.

Best wishes,  Marc


Re: Multiple vertices generated for the same index value and vertex properties missing with RF3

sauverma
 

Hi Marc

==>------------------------------------------------------------------------------------------------
Vertex Label Name              | Partitioned | Static                                             |
---------------------------------------------------------------------------------------------------
node                           | false       | false                                              |
---------------------------------------------------------------------------------------------------
Edge Label Name                | Directed    | Unidirected | Multiplicity                         |
---------------------------------------------------------------------------------------------------
link                           | true        | false       | SIMPLE                               |
---------------------------------------------------------------------------------------------------
Property Key Name              | Cardinality | Data Type                                          |
---------------------------------------------------------------------------------------------------
country_LUX                    | SET         | class java.lang.Integer                            |
country_FRA                    | SET         | class java.lang.Integer                            |
country_CHE                    | SET         | class java.lang.Integer                            |
country_ESP                    | SET         | class java.lang.Integer                            |
dpts_0                         | SINGLE      | class java.lang.Long                               |
dpts_100                       | SINGLE      | class java.lang.Long                               |
dpts_101                       | SINGLE      | class java.lang.Long                               |
dpts_1011                      | SINGLE      | class java.lang.Long                               |
dpts_103                       | SINGLE      | class java.lang.Long                               |
dpts_1038                      | SINGLE      | class java.lang.Long                               |
dpts_104                       | SINGLE      | class java.lang.Long                               |
dpts_1045                      | SINGLE      | class java.lang.Long                               |
dpts_105                       | SINGLE      | class java.lang.Long                               |
dpts_1055                      | SINGLE      | class java.lang.Long                               |
dpts_1076                      | SINGLE      | class java.lang.Long                               |
dpts_1077                      | SINGLE      | class java.lang.Long                               |
dpts_1081                      | SINGLE      | class java.lang.Long                               |
dpts_1085                      | SINGLE      | class java.lang.Long                               |
dpts_1099                      | SINGLE      | class java.lang.Long                               |
dpts_1110                      | SINGLE      | class java.lang.Long                               |
dpts_1129                      | SINGLE      | class java.lang.Long                               |
dpts_1141                      | SINGLE      | class java.lang.Long                               |
dpts_1146                      | SINGLE      | class java.lang.Long                               |
dpts_1147                      | SINGLE      | class java.lang.Long                               |
dpts_1148                      | SINGLE      | class java.lang.Long                               |
dpts_1168                      | SINGLE      | class java.lang.Long                               |
dpts_118                       | SINGLE      | class java.lang.Long                               |
dpts_12                        | SINGLE      | class java.lang.Long                               |
dpts_120                       | SINGLE      | class java.lang.Long                               |
dpts_1201                      | SINGLE      | class java.lang.Long                               |
dpts_121                       | SINGLE      | class java.lang.Long                               |
dpts_1222                      | SINGLE      | class java.lang.Long                               |
dpts_123                       | SINGLE      | class java.lang.Long                               |
dpts_1249                      | SINGLE      | class java.lang.Long                               |
dpts_1252                      | SINGLE      | class java.lang.Long                               |
dpts_1257                      | SINGLE      | class java.lang.Long                               |
dpts_1258                      | SINGLE      | class java.lang.Long                               |
dpts_1263                      | SINGLE      | class java.lang.Long                               |
dpts_1271                      | SINGLE      | class java.lang.Long                               |
dpts_1290                      | SINGLE      | class java.lang.Long                               |
dpts_1292                      | SINGLE      | class java.lang.Long                               |
dpts_1295                      | SINGLE      | class java.lang.Long                               |
dpts_13                        | SINGLE      | class java.lang.Long                               |
dpts_1302                      | SINGLE      | class java.lang.Long                               |
dpts_1314                      | SINGLE      | class java.lang.Long                               |
dpts_1316                      | SINGLE      | class java.lang.Long                               |
dpts_1325                      | SINGLE      | class java.lang.Long                               |
dpts_1326                      | SINGLE      | class java.lang.Long                               |
dpts_1332                      | SINGLE      | class java.lang.Long                               |
dpts_1344                      | SINGLE      | class java.lang.Long                               |
dpts_1346                      | SINGLE      | class java.lang.Long                               |
dpts_1348                      | SINGLE      | class java.lang.Long                               |
dpts_135                       | SINGLE      | class java.lang.Long                               |
dpts_1353                      | SINGLE      | class java.lang.Long                               |
dpts_1354                      | SINGLE      | class java.lang.Long                               |
dpts_1357                      | SINGLE      | class java.lang.Long                               |
dpts_1361                      | SINGLE      | class java.lang.Long                               |
dpts_1363                      | SINGLE      | class java.lang.Long                               |
dpts_1380                      | SINGLE      | class java.lang.Long                               |
dpts_1382                      | SINGLE      | class java.lang.Long                               |
dpts_1396                      | SINGLE      | class java.lang.Long                               |
dpts_1401                      | SINGLE      | class java.lang.Long                               |
dpts_1406                      | SINGLE      | class java.lang.Long                               |
dpts_1408                      | SINGLE      | class java.lang.Long                               |
country_NLD                    | SET         | class java.lang.Integer                            |
dpts_1409                      | SINGLE      | class java.lang.Long                               |
dpts_1410                      | SINGLE      | class java.lang.Long                               |
dpts_1415                      | SINGLE      | class java.lang.Long                               |
dpts_1429                      | SINGLE      | class java.lang.Long                               |
dpts_1441                      | SINGLE      | class java.lang.Long                               |
dpts_1443                      | SINGLE      | class java.lang.Long                               |
dpts_1479                      | SINGLE      | class java.lang.Long                               |
dpts_1480                      | SINGLE      | class java.lang.Long                               |
dpts_1491                      | SINGLE      | class java.lang.Long                               |
dpts_18                        | SINGLE      | class java.lang.Long                               |
dpts_1801                      | SINGLE      | class java.lang.Long                               |
dpts_21                        | SINGLE      | class java.lang.Long                               |
dpts_212                       | SINGLE      | class java.lang.Long                               |
dpts_213                       | SINGLE      | class java.lang.Long                               |
dpts_215                       | SINGLE      | class java.lang.Long                               |
dpts_216                       | SINGLE      | class java.lang.Long                               |
dpts_22                        | SINGLE      | class java.lang.Long                               |
dpts_222                       | SINGLE      | class java.lang.Long                               |
dpts_226                       | SINGLE      | class java.lang.Long                               |
dpts_229                       | SINGLE      | class java.lang.Long                               |
dpts_233                       | SINGLE      | class java.lang.Long                               |
dpts_237                       | SINGLE      | class java.lang.Long                               |
dpts_239                       | SINGLE      | class java.lang.Long                               |
dpts_24                        | SINGLE      | class java.lang.Long                               |
dpts_255                       | SINGLE      | class java.lang.Long                               |
dpts_258                       | SINGLE      | class java.lang.Long                               |
dpts_26                        | SINGLE      | class java.lang.Long                               |
dpts_27                        | SINGLE      | class java.lang.Long                               |
dpts_28                        | SINGLE      | class java.lang.Long                               |
dpts_29                        | SINGLE      | class java.lang.Long                               |
dpts_307                       | SINGLE      | class java.lang.Long                               |
dpts_31                        | SINGLE      | class java.lang.Long                               |
dpts_313                       | SINGLE      | class java.lang.Long                               |
dpts_314                       | SINGLE      | class java.lang.Long                               |
dpts_320                       | SINGLE      | class java.lang.Long                               |
dpts_322                       | SINGLE      | class java.lang.Long                               |
dpts_329                       | SINGLE      | class java.lang.Long                               |
dpts_33                        | SINGLE      | class java.lang.Long                               |
dpts_331                       | SINGLE      | class java.lang.Long                               |
dpts_335                       | SINGLE      | class java.lang.Long                               |
dpts_336                       | SINGLE      | class java.lang.Long                               |
dpts_338                       | SINGLE      | class java.lang.Long                               |
dpts_34                        | SINGLE      | class java.lang.Long                               |
dpts_346                       | SINGLE      | class java.lang.Long                               |
dpts_35                        | SINGLE      | class java.lang.Long                               |
dpts_362                       | SINGLE      | class java.lang.Long                               |
dpts_37                        | SINGLE      | class java.lang.Long                               |
dpts_370                       | SINGLE      | class java.lang.Long                               |
dpts_372                       | SINGLE      | class java.lang.Long                               |
dpts_374                       | SINGLE      | class java.lang.Long                               |
dpts_376                       | SINGLE      | class java.lang.Long                               |
dpts_391                       | SINGLE      | class java.lang.Long                               |
dpts_395                       | SINGLE      | class java.lang.Long                               |
dpts_41                        | SINGLE      | class java.lang.Long                               |
dpts_416                       | SINGLE      | class java.lang.Long                               |
dpts_45                        | SINGLE      | class java.lang.Long                               |
dpts_50                        | SINGLE      | class java.lang.Long                               |
dpts_516                       | SINGLE      | class java.lang.Long                               |
dpts_521                       | SINGLE      | class java.lang.Long                               |
dpts_522                       | SINGLE      | class java.lang.Long                               |
dpts_525                       | SINGLE      | class java.lang.Long                               |
dpts_529                       | SINGLE      | class java.lang.Long                               |
dpts_532                       | SINGLE      | class java.lang.Long                               |
dpts_533                       | SINGLE      | class java.lang.Long                               |
dpts_556                       | SINGLE      | class java.lang.Long                               |
dpts_56                        | SINGLE      | class java.lang.Long                               |
dpts_566                       | SINGLE      | class java.lang.Long                               |
dpts_568                       | SINGLE      | class java.lang.Long                               |
dpts_575                       | SINGLE      | class java.lang.Long                               |
dpts_58                        | SINGLE      | class java.lang.Long                               |
dpts_59                        | SINGLE      | class java.lang.Long                               |
dpts_598                       | SINGLE      | class java.lang.Long                               |
dpts_611                       | SINGLE      | class java.lang.Long                               |
dpts_613                       | SINGLE      | class java.lang.Long                               |
dpts_620                       | SINGLE      | class java.lang.Long                               |
dpts_625                       | SINGLE      | class java.lang.Long                               |
dpts_627                       | SINGLE      | class java.lang.Long                               |
dpts_63                        | SINGLE      | class java.lang.Long                               |
dpts_634                       | SINGLE      | class java.lang.Long                               |
dpts_637                       | SINGLE      | class java.lang.Long                               |
dpts_648                       | SINGLE      | class java.lang.Long                               |
dpts_654                       | SINGLE      | class java.lang.Long                               |
dpts_667                       | SINGLE      | class java.lang.Long                               |
dpts_67                        | SINGLE      | class java.lang.Long                               |
dpts_678                       | SINGLE      | class java.lang.Long                               |
dpts_68                        | SINGLE      | class java.lang.Long                               |
dpts_685                       | SINGLE      | class java.lang.Long                               |
dpts_69                        | SINGLE      | class java.lang.Long                               |
dpts_697                       | SINGLE      | class java.lang.Long                               |
dpts_7123                      | SINGLE      | class java.lang.Long                               |
dpts_735                       | SINGLE      | class java.lang.Long                               |
dpts_738                       | SINGLE      | class java.lang.Long                               |
dpts_75                        | SINGLE      | class java.lang.Long                               |
dpts_751                       | SINGLE      | class java.lang.Long                               |
dpts_754                       | SINGLE      | class java.lang.Long                               |
dpts_76                        | SINGLE      | class java.lang.Long                               |
dpts_768                       | SINGLE      | class java.lang.Long                               |
dpts_78                        | SINGLE      | class java.lang.Long                               |
dpts_784                       | SINGLE      | class java.lang.Long                               |
dpts_799                       | SINGLE      | class java.lang.Long                               |
dpts_800                       | SINGLE      | class java.lang.Long                               |
dpts_801                       | SINGLE      | class java.lang.Long                               |
dpts_806                       | SINGLE      | class java.lang.Long                               |
dpts_807                       | SINGLE      | class java.lang.Long                               |
dpts_808                       | SINGLE      | class java.lang.Long                               |
dpts_809                       | SINGLE      | class java.lang.Long                               |
dpts_810                       | SINGLE      | class java.lang.Long                               |
dpts_82                        | SINGLE      | class java.lang.Long                               |
dpts_820                       | SINGLE      | class java.lang.Long                               |
dpts_824                       | SINGLE      | class java.lang.Long                               |
dpts_84                        | SINGLE      | class java.lang.Long                               |
dpts_86                        | SINGLE      | class java.lang.Long                               |
dpts_87                        | SINGLE      | class java.lang.Long                               |
dpts_871                       | SINGLE      | class java.lang.Long                               |
dpts_876                       | SINGLE      | class java.lang.Long                               |
dpts_90901                     | SINGLE      | class java.lang.Long                               |
dpts_946                       | SINGLE      | class java.lang.Long                               |
dpts_95                        | SINGLE      | class java.lang.Long                               |
dpts_96                        | SINGLE      | class java.lang.Long                               |
dpts_963                       | SINGLE      | class java.lang.Long                               |
dpts_979                       | SINGLE      | class java.lang.Long                               |
dpts_98                        | SINGLE      | class java.lang.Long                               |
dpts_984                       | SINGLE      | class java.lang.Long                               |
dpts_988                       | SINGLE      | class java.lang.Long                               |
dpts_99                        | SINGLE      | class java.lang.Long                               |
device_deviceos                | SET         | class java.lang.String                             |
device_ipaddress               | SET         | class java.lang.String                             |
id                             | SINGLE      | class java.lang.String                             |
country_AUT                    | SET         | class java.lang.Integer                            |
type                           | SINGLE      | class java.lang.String                             |
soft_del                       | SINGLE      | class java.lang.Boolean                            |
country_IRL                    | SET         | class java.lang.Integer                            |
country_ITA                    | SET         | class java.lang.Integer                            |
country_GBR                    | SET         | class java.lang.Integer                            |
country_BEL                    | SET         | class java.lang.Integer                            |
country_DEU                    | SET         | class java.lang.Integer                            |
country_GEO                    | SET         | class java.lang.Integer                            |
---------------------------------------------------------------------------------------------------
Vertex Index Name              | Type        | Unique    | Backing        | Key:           Status |
---------------------------------------------------------------------------------------------------
idIndex                        | Composite   | true      | internalindex  | id:           ENABLED |
                               |             |           |                | type:         ENABLED |
---------------------------------------------------------------------------------------------------
Edge Index (VCI) Name          | Type        | Unique    | Backing        | Key:           Status |
---------------------------------------------------------------------------------------------------
---------------------------------------------------------------------------------------------------
Relation Index                 | Type        | Direction | Sort Key       | Order    |     Status |
---------------------------------------------------------------------------------------------------

After modifying index and properties to ConsistenceModifier.LOCK as per https://docs.janusgraph.org/advanced-topics/eventual-consistency/
the issue seems to be fixed

Thanks


Re: How to circumvent transaction cache?

Boxuan Li
 

My thoughts are:

1) As you said, you wanted to be able to disable the transaction cache so that you can read from database again. I have provided a solution here: https://lists.lfaidata.foundation/g/janusgraph-users/message/5668 A PR is available here: https://github.com/JanusGraph/janusgraph/pull/2502
2) An alternative approach (apart from your external locking approach) is to use JanusGraph built-in locking mechanism, as we have discussed here: https://groups.google.com/g/janusgraph-users/c/WzsO78ndobA/m/e6GzFXI5CQAJ

Although the above approaches will likely work most of the time, they are not guaranteed to be robust due to the eventual consistency nature of HBase. If you need ACID you should switch to FoundationDB backend. To my best knowledge, there is no way that JanusGraph can provide ACID on top of an eventual consistent storage backend, because the graph instances can only “communicate" with each other via the underlying storage backend.

On Mar 8, 2021, at 9:40 PM, timon.schneider@... wrote:

Currently using HBase.

Consider the following:
User A decides to set isPublished of Vertex X from false to true, does not commit yet.
User B changes isPublished of Vertex X from false to true and commits immediately.
User A commits and will get an error because the property value is not the same anymore as at the start of the transaction.

Why wouldn't it be possible for JG to provide user A with select for update functionality that allows user A to select vertex X for update, do edits to other elements, commit and get the same message as in the example above if the property on vertex X is changed?


Re: Multiple vertices generated for the same index value and vertex properties missing with RF3

hadoopmarc@...
 

Hi Saurabh,

To be sure, in the valueMap(true) return value I see both the id token and an "id" property key appear (I am not even sure whether an "id" property key is allowed). Is this "id" property key something that was part of the input data of the graph? Can you also show the graph schema using:
mgmt = graph.openManagement()
mgmt.printSchema()
Best wishes,    Marc


Re: Script16.groovy: 2: unable to resolve class StandardJanusGraph

Vinayak Bali
 

Hi Marc,

The same code works for JanusGraphFactory but not for ConfiguredGraphFactory. I investigated issue further. For ConfiguredGraphFactory we establish remote connection using following commands:
bin/gremlin.sh
:remote connect tinkerpop.server conf/remote.yaml session
:remote console

The imports are not working after establishing remote connection. Imports works without remote connection. How can we solve this problem ???

Thanks & Regards,
Vinayak

On Tue, 9 Mar 2021, 9:30 pm , <hadoopmarc@...> wrote:
Hi Vinayak,

I only replayed exactly your imports, not the rest of your code. Downloading dependencies may depend on the grape configs of your system, see:

https://docs.janusgraph.org/basics/server/#using-tinkerpop-gremlin-server-with-janusgraph
https://tinkerpop.apache.org/docs/current/reference/#gremlin-applications

Best wishes,    Marc


Re: JMX authentication for cassandra

hadoopmarc@...
 

Hi Vinayak,

Please review the change you made in the cassandra-env.sh, it does not make sense.  I do not know about JMX settings for Cassandra either, but the cassandra-env.sh is written such that you do not have to.

Best wishes,  Marc

941 - 960 of 6661