[flink] Change the name of MultiTablesReadOperator to avoid using sam…

…e name with source (#5033)
apache · Feb 7, 2025 · 58cab01 · 58cab01
1 parent f448fd1
commit 58cab01
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...n/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareStreamingSource.java b/...n/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareStreamingSource.java
@@ -129,6 +129,9 @@ public static DataStream<RowData> buildSource(
                 .partitionCustom(
                         (key, numPartitions) -> key % numPartitions,
                         split -> ((DataSplit) split.f0).bucket())
-                .transform(name, typeInfo, new MultiTablesReadOperator(catalogLoader, true));
+                .transform(
+                        "BucketsTableReader",
+                        typeInfo,
+                        new MultiTablesReadOperator(catalogLoader, true));
     }
 }