fix

apache · Dec 16, 2024 · 87faa85 · 87faa85
1 parent 7d6a79e
commit 87faa85
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CopyFileOperator.java b/...ink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CopyFileOperator.java
@@ -34,6 +34,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.HashMap;
 import java.util.Map;
 
 /** A Operator to copy files. */
@@ -63,6 +64,8 @@ public void open() throws Exception {
                 FlinkCatalogFactory.createPaimonCatalog(Options.fromMap(sourceCatalogConfig));
         targetCatalog =
                 FlinkCatalogFactory.createPaimonCatalog(Options.fromMap(targetCatalogConfig));
+        srcLocations = new HashMap<>();
+        targetLocations = new HashMap<>();
     }
 
     @Override