[flink] change env.fromData to fromElements for compatibility with fl…

…ink 1.18 and lower version
apache · Nov 18, 2024 · 03753cf · 03753cf
1 parent 203db41
commit 03753cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...imon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java b/...imon-flink-common/src/main/java/org/apache/paimon/flink/orphan/FlinkOrphanFilesClean.java
@@ -279,7 +279,7 @@ public void processElement2(StreamRecord<String> element) {
                                 });
 
         if (deletedInLocal.get() != 0) {
-            deleted = deleted.union(env.fromData(deletedInLocal.get()));
+            deleted = deleted.union(env.fromElements(deletedInLocal.get()));
         }
         return deleted;
     }