Sparksee se bloque sur la session close

Question

Lorsque j'exécute la création de relations, il se bloque à la fermeture de la session.

Le code:

@Override 
public boolean applyCreate(final RelationshipStorage storage, final long snapshotId) 
{ 
    final Session sess = db.newSession(); 
    final Graph graph = sess.getGraph(); 
    final Objects startObjs = findNode(graph, storage.getStartNode()); 
    final Objects endObjs = findNode(graph, storage.getEndNode()); 

    if(startObjs == null || endObjs == null) 
    { 
     if(startObjs != null) 
     { 
      startObjs.close(); 
     } 
     if(endObjs != null) 
     { 
      endObjs.close(); 
     } 
     sess.close(); 
     return false; 
    } 

    final ObjectsIterator startIt = startObjs.iterator(); 
    final ObjectsIterator endIt = endObjs.iterator(); 

    while(startIt.hasNext()) 
    { 
     long startNode = startIt.next(); 
     while (endIt.hasNext()) 
     { 
      final long endNode = endIt.next(); 

      int edgeType = graph.findType(storage.getId()); 
      if (Type.InvalidType == edgeType) 
      { 
       edgeType = graph.newEdgeType(storage.getId(), true, false); 
      } 

      final long relationship = graph.findOrCreateEdge(edgeType, startNode, endNode); 
      for (final Map.Entry<String, Object> entry : storage.getProperties().entrySet()) 
      { 
       graph.setAttribute(relationship, 
         SparkseeUtils.createOrFindAttributeType(entry.getKey(), entry.getValue(), Type.GlobalType, graph), 
         SparkseeUtils.getValue(entry.getValue())); 
      } 

      int snapshotAttributeId = SparkseeUtils.createOrFindAttributeType(Constants.TAG_SNAPSHOT_ID, snapshotId, Type.GlobalType, graph); 
      graph.setAttribute(relationship, snapshotAttributeId, SparkseeUtils.getValue(snapshotId)); 

      try 
      { 
       int hashAttributeId = SparkseeUtils.createOrFindAttributeType(Constants.TAG_HASH, " ", Type.GlobalType, graph); 
       graph.setAttribute(relationship, hashAttributeId, SparkseeUtils.getValue(HashCreator.sha1FromRelationship(storage))); 
      } 
      catch (NoSuchAlgorithmException e) 
      { 
       Log.getLogger().warn("Couldn't execute create node transaction in server: " + id, e); 
       endObjs.close(); 
       startObjs.close(); 
       startIt.close(); 
       endIt.close(); 
       sess.close(); 
       return false; 
      } 
      Log.getLogger().warn("Successfully executed create relationship transaction in server: " + id); 
     } 
    } 

    startObjs.close(); 
    endObjs.close(); 
    startIt.close(); 
    endIt.close(); 
    sess.close(); 
    return true; 
} 

/** 
* Return a Objects array matching the nodeType and properties. 
* @param graph the graph. 
* @param storage the storage of the node. 
* @return Objects which match the attributes. 
*/ 
private Objects findNode(final Graph graph, final NodeStorage storage) 
{ 
    Objects objects = null; 

    if(!storage.getId().isEmpty()) 
    { 
     int nodeTypeId = SparkseeUtils.createOrFindNodeType(storage, graph); 
     objects = graph.select(nodeTypeId); 
    } 

    for (final Map.Entry<String, Object> entry : storage.getProperties().entrySet()) 
    { 
     final int attributeId = graph.findAttribute(Type.GlobalType, entry.getKey()); 

     if (objects == null || objects.isEmpty()) 
     { 
      if(objects != null) 
      { 
       objects.close(); 
      } 
      objects = graph.select(attributeId, Condition.Equal, SparkseeUtils.getValue(entry.getValue())); 
     } 
     else 
     { 
      objects = graph.select(attributeId, Condition.Equal, SparkseeUtils.getValue(entry.getValue()), objects); 
     } 
    } 
    return objects; 
} 

Le crashlog:

clôture sparkseejava.lang.RuntimeException: les données de session toujours active lors de la fermeture à com.sparsity.sparkseejavawrapJNI.delete_sparksee_gdb_Session (natif Method) à com.sparsity.sparksee.gdb.Session.delete (Session.java:32) à com.sparsity.sparksee.gdb.Session.close (Session.java:40) au main.java.com.bag.server .database.SparkseeDa tabaseAccess.applyCreate (SparkseeDatabaseAccess.java:595) à main.java.com.bag.main.DatabaseLoader.loadGraph (DatabaseLoader.java:97) à main.java.com.bag.main.DatabaseLoader.main (DatabaseLoader.java:191)

Je ne vois pas ce que je dois encore fermer. J'ai fermé tous les itérateurs et objets.

Answer 1

réponse originale sur les groupes Google: https://groups.google.com/forum/#!topic/sparksee/brcfhvFzdjg

je dois fermer les objets temporaires « objets » avant que je cède une nouvelle à lui.

Objets tempObj = graph.select (attributeId, Condition.Equal, SparkseeUtils.getValue (entry.getValue()), objets); objects.close(); objects = tempObj;