Skip to content
Permalink
Browse files
Fix error in statistical insertion result
Fix #3

Change-Id: Ia3b4956b32de5bf9f43b6c88ee19704f881af1e7
  • Loading branch information
Linary authored and javeme committed Oct 11, 2018
1 parent c4db0f9 commit ca5df87f21825811b3d5c30bae98a52bee35c3b9
Showing 1 changed file with 5 additions and 4 deletions.
@@ -33,6 +33,7 @@

import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.loader.exception.InsertException;
import com.baidu.hugegraph.loader.exception.LoadException;
import com.baidu.hugegraph.loader.executor.HugeClients;
import com.baidu.hugegraph.loader.executor.LoadLogger;
import com.baidu.hugegraph.loader.executor.LoadOptions;
@@ -141,15 +142,15 @@ public void submitVertexBatch(List<Vertex> batch) {

@Override
public void onSuccess(Integer size) {
available.release();
successNum.add(size);
available.release();
printProgress("Vertices", BATCH_PRINT_FREQUENCY, size);
}

@Override
public void onFailure(Throwable t) {
available.release();
submitVerticesInSingleMode(batch);
available.release();
}
});
}
@@ -168,15 +169,15 @@ public void submitEdgeBatch(List<Edge> batch) {

@Override
public void onSuccess(Integer size) {
available.release();
successNum.add(size);
available.release();
printProgress("Edges", BATCH_PRINT_FREQUENCY, size);
}

@Override
public void onFailure(Throwable t) {
available.release();
submitEdgesInSingleMode(batch);
available.release();
}
});
}

0 comments on commit ca5df87

Please sign in to comment.