[incubator-paimon] branch master updated: [flink] Use : instead of -> for operator name (#1796)

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 32ed67ba6 [flink] Use : instead of -> for operator name (#1796)
32ed67ba6 is described below

commit 32ed67ba6d43cd8576aabf1f0a43f501d8a8afdd
Author: hehuiyuan <471627...@qq.com>
AuthorDate: Sun Aug 13 21:25:02 2023 +0800

    [flink] Use : instead of -> for operator name (#1796)
---
 .../src/main/java/org/apache/paimon/flink/sink/FlinkSink.java         | 4 ++--
 .../org/apache/paimon/flink/source/BucketUnawareCompactSource.java    | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java
index afe9fc917..5c60b0304 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSink.java
@@ -150,7 +150,7 @@ public abstract class FlinkSink<T> implements Serializable {
         SingleOutputStreamOperator<Committable> written =
                 input.transform(
                                 (writeOnly ? WRITER_WRITE_ONLY_NAME : 
WRITER_NAME)
-                                        + " -> "
+                                        + " : "
                                         + table.name(),
                                 new CommittableTypeInfo(),
                                 createWriteOperator(
@@ -186,7 +186,7 @@ public abstract class FlinkSink<T> implements Serializable {
 
         SingleOutputStreamOperator<?> committed =
                 written.transform(
-                                GLOBAL_COMMITTER_NAME + " -> " + table.name(),
+                                GLOBAL_COMMITTER_NAME + " : " + table.name(),
                                 new CommittableTypeInfo(),
                                 new CommitterOperator<>(
                                         streamingCheckpointEnabled,
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BucketUnawareCompactSource.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BucketUnawareCompactSource.java
index bb5a7730a..83cf3600a 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BucketUnawareCompactSource.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/BucketUnawareCompactSource.java
@@ -125,7 +125,7 @@ public class BucketUnawareCompactSource extends 
RichSourceFunction<AppendOnlyCom
                 new CompactionTaskTypeInfo(),
                 sourceOperator,
                 false,
-                COMPACTION_COORDINATOR_NAME + " -> " + tableIdentifier,
+                COMPACTION_COORDINATOR_NAME + " : " + tableIdentifier,
                 streaming ? Boundedness.CONTINUOUS_UNBOUNDED : 
Boundedness.BOUNDED);
     }
 }