(flink-cdc) branch master updated: [FLINK-36111][minor][pipeline-connector/paimon] Improve MultiTableCommittableChannelComputer Topology name

[leonard]

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

leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new aedccb698 [FLINK-36111][minor][pipeline-connector/paimon] Improve 
MultiTableCommittableChannelComputer Topology name
aedccb698 is described below

commit aedccb698e318d8bef58a40df1666d2c051ee554
Author: MOBIN <18814118...@163.com>
AuthorDate: Wed Aug 21 00:12:55 2024 +0800

    [FLINK-36111][minor][pipeline-connector/paimon] Improve 
MultiTableCommittableChannelComputer Topology name
    
    This closes #3559
---
 .../paimon/sink/v2/MultiTableCommittableChannelComputer.java         | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/MultiTableCommittableChannelComputer.java
 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/MultiTableCommittableChannelComputer.java
index 6694b4074..cd633ff42 100644
--- 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/MultiTableCommittableChannelComputer.java
+++ 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/MultiTableCommittableChannelComputer.java
@@ -56,4 +56,9 @@ public class MultiTableCommittableChannelComputer
             return Math.floorMod(Objects.hash(committableMessage), 
numChannels);
         }
     }
+
+    @Override
+    public String toString() {
+        return "shuffle by table";
+    }
 }