rename the operator

apache · Feb 7, 2025 · 3afef00 · 3afef00
1 parent 17a7d4d
commit 3afef00
Showing 1 changed file with 1 addition 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
@@ -130,7 +130,7 @@ public static DataStream<RowData> buildSource(
                         (key, numPartitions) -> key % numPartitions,
                         split -> ((DataSplit) split.f0).bucket())
                 .transform(
-                        name + "-transform",
+                        name + "-toRow",
                         typeInfo,
                         new MultiTablesReadOperator(catalogLoader, true));
     }