improve: Log invalid edges

itinycheng · Nov 14, 2023 · db1538a · db1538a
1 parent cac4fc1
commit db1538a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/.../java/org/apache/flink/connector/janusgraph/internal/executor/JanusGraphEdgeExecutor.java b/.../java/org/apache/flink/connector/janusgraph/internal/executor/JanusGraphEdgeExecutor.java
@@ -105,6 +105,11 @@ protected void execute(RowData record, JanusGraphTransaction transaction) {
     private void createEdge(Object[] values, JanusGraphTransaction transaction) {
         Vertex inV = inVertexSearcher.search(values, transaction);
         Vertex outV = outVertexSearcher.search(values, transaction);
+        if (inV == null || outV == null) {
+            LOG.debug("in vertex: {} and out vertex: {} must be present", inV, outV);
+            return;
+        }
+
         Edge created = outV.addEdge(values[labelIndex].toString(), inV);
         for (int i = 0; i < values.length; i++) {
             if (!nonWriteColumnIndexes.contains(i)) {