타이탄/야누스 그래프 이상한 일관성 문제 - 같은 에지 ID

Question

와 여러 가장자리 우리는 가상 코어-7 시스템에 datastax-DDC에서 카산드라 버전 3.9.0-1와 타이탄 1.0.0을 사용하고 있습니다.

• 같은 가장자리 ID를 가진 여러 가장자리는 값이 다릅니 다만 몇 가지 이상한 문제가 있습니다.

  gV(). ('msid', 6171699) .outE ('prio_child'). ('hostid_e', 153) .as ('e') inV().) ALL 기타 사항 서보 -OFF ('E') ==> E [54ekdatm-1lezwb4-45cl-195s9km8] 3,471,761,488-prio_child-> 98305011872] ==> E [54ekdatm-1lezwb4-45cl-195s9km8] 3,471,761,488 -prio_child-> 98305011872]

• 더 제한

  GV(). (6171699 '을 MSID')를 갖는다 .outE ('prio_child'). (카운트)
  을 적용한 후, 더 많은 결과를 얻기 0 ==>60

  GV(). ('MSID'6,171,699) .outE ('prio_child')을 갖는다. 갖는다 ('hostid_e 153) .count()
  ==>66

타이탄 문서 Eventually Consistent Backends에 의해 제안 난, ConsistencyModifier.LOCK 설정을 시도했다, 그러나 그것은 도움이되지 않았습니다. 나는 여전히 임의적 결과를 얻고있다.

Answer 1

타이탄 1.0.0 타이탄이 유지되고 더 이상도 카산드라 3.x를 http://s3.thinkaurelius.com/docs/titan/1.0.0/version-compat.html

와 호환되지 않습니다. JanusGraph http://janusgraph.org/은 Titan이 중단 된 곳에서 진행되었으며 적극적으로 업데이트되고 유지 관리되고 있습니다.

Answer 2

Data Consistency에 따라 재생하고 수정할 수있었습니다. ConsistencyModifier를 설정 한 후 다음 명령이 누락되었습니다.

mgmt.commit()

다음은 cassandra 버전 인 cassandra 2.1.x와 cassandra 3.9.x와 함께 문제를 재현 한 코드입니다.

 

    TitanGraph graph = TitanFactory.open("/opt/cmsgraph/config/edgepoc.conf"); 
    try { 
     int parent = -2128958273; 
     int child = 58541705; 
     int hostid = 83; 
     int numThreads = 100; 
     Thread[] threads = new Thread[numThreads]; 
     for(int i =0; i < numThreads; i++) { 
      threads[i] = new Thread(new EdgeUpdator(graph, parent, child, hostid)); 
     } 
     for(int i =0; i < numThreads; i++) { 
      threads[i].start(); 
     } 
     for(int i = 0; i < numThreads; i++) { 
      threads[i].join(); 
     } 
    } finally { 
     graph.close(); 
    } 

    private static class EdgeUpdator implements Runnable { 
     public EdgeUpdator(TitanGraph graph, int parent, int child, int hostid) { 
      this.graph = graph; 
      this.parent = parent; 
      this.child = child; 
      this.hostid = hostid; 
     } 

     private int parent; 
     private int child; 
     private int hostid; 
     private TitanGraph graph; 

     public void run() { 
      TitanTransaction trxn = graph.newTransaction(); 
      GraphTraversalSource g = trxn.traversal(); 
      Edge edge = (Edge)g.V().has("msid", parent).outE("prio_child").has("hostid_e", hostid).as("e").inV().has("msid", child).select("e").next(); 
      Random random = new Random(System.nanoTime()); 
      edge.property("updatedAt_e", random.nextLong()); 
      edge.property("plrank", random.nextInt()); 
      trxn.commit(); 
     } 
    } 

위의 코드를 실행하기 전에. 나는 참조 :

 

    gremlin> g.V().has('msid', -2128958273).outE('prio_child').has('hostid_e', 83).as('e').inV().has('msid', 58541705).select('e') 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    gremlin> g.V().has('msid', -2128958273).outE('prio_child').has('hostid_e', 83).as('e').inV().has('msid', 58541705).select('e').count() 
    ==>1 
    gremlin> g.V().has('msid', -2128958273).outE('prio_child').has('hostid_e', 83).count() 
    ==>104 

코드를 실행 한 후, 내가 볼 :

ConsitencyModifier.LOCK을 적용한 후에 "prio_child"가장자리, 내가 10 개 스레드 (9)가 예외를 다음과 같이 실패 관찰

 

    gremlin> g.V().has('msid', -2128958273).outE('prio_child').has('hostid_e', 83).as('e').inV().has('msid', 58541705).select('e') 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    ==>e[239suvpz-17ofqw-41ed-9eutzq8][73363640-prio_child->20489355296] 
    gremlin> g.V().has('msid', -2128958273).outE('prio_child').has('hostid_e', 83).as('e').inV().has('msid', 58541705).select('e').count() 
    ==>10 
    gremlin> g.V().has('msid', -2128958273).outE('prio_child').has('hostid_e', 83).as('e').inV().has('msid', 58541705).select('e').dedup().count() 
    ==>1 
    gremlin> g.V().has('msid', -2128958273).outE('prio_child').has('hostid_e', 83).count() 
    ==>113 
    gremlin> g.V().has('msid', -2128958273).outE('prio_child').count() 
    ==>104 

및 , 나는 같은 가장자리 ID 문제와 함께 여러 가장자리가 발생하지 않았다.

 
Exception in thread "Thread-8" org.apache.tinkerpop.gremlin.process.traversal.util.FastNoSuchElementException 

에 따라 내가 만든 정확한 변경 사항은 다음과 같습니다

 

    mgmt = graph.openManagement() 
    prio_child=mgmt.getRelationType('prio_child') 
    mgmt.setConsistency(prio_child, ConsistencyModifier.LOCK) 
    mgmt.commit()