Fix bug: flink-loader SchemaCache init

fix #333
apache · Sep 20, 2022 · d09a1f7 · d09a1f7
1 parent d75f263
commit d09a1f7
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/flink/HugeGraphOutputFormat.java b/hugegraph-loader/src/main/java/com/baidu/hugegraph/loader/flink/HugeGraphOutputFormat.java
@@ -90,6 +90,7 @@ private Map<ElementBuilder, List<String>> initBuilders() {
             builders.put(new EdgeBuilder(loadContext, this.struct, edgeMapping),
                          new ArrayList<>());
         }
+        loadContext.updateSchemaCache();
         return builders;
     }