From 5693f577060369cb8ad13ff8e534f02c72aa3635 Mon Sep 17 00:00:00 2001
From: MOBIN-F <18814118038@163.com>
Date: Tue, 20 Aug 2024 17:29:43 +0800
Subject: [PATCH] Override toString method in
 MultiTableCommittableChannelComputer class

---
 .../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 6694b40747f..cd633ff4271 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 int channel(CommittableMessage<MultiTableCommittable> committableMessage)
             return Math.floorMod(Objects.hash(committableMessage), numChannels);
         }
     }
+
+    @Override
+    public String toString() {
+        return "shuffle by table";
+    }
 }