(paimon) branch master updated: [flink] Change the name of MultiTablesReadOperator to avoid using same name with source (#5033)

[yuzelin]

This is an automated email from the ASF dual-hosted git repository.

yuzelin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 58cab013c3 [flink] Change the name of MultiTablesReadOperator to avoid 
using same name with source (#5033)
58cab013c3 is described below

commit 58cab013c34e27ac530e1a5f7e7c4945bf1329bd
Author: LsomeYeah <94825748+lsomey...@users.noreply.github.com>
AuthorDate: Fri Feb 7 15:24:45 2025 +0800

    [flink] Change the name of MultiTablesReadOperator to avoid using same name 
with source (#5033)
---
 .../paimon/flink/source/operator/CombinedAwareStreamingSource.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareStreamingSource.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareStreamingSource.java
index a23a3b41a4..782ef1ef0f 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareStreamingSource.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/CombinedAwareStreamingSource.java
@@ -129,6 +129,9 @@ public class CombinedAwareStreamingSource extends 
CombinedCompactorSource<Tuple2
                 .partitionCustom(
                         (key, numPartitions) -> key % numPartitions,
                         split -> ((DataSplit) split.f0).bucket())
-                .transform(name, typeInfo, new 
MultiTablesReadOperator(catalogLoader, true));
+                .transform(
+                        "BucketsTableReader",
+                        typeInfo,
+                        new MultiTablesReadOperator(catalogLoader, true));
     }
 }