fix done

Author: ThorneANN

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java

@@ -64,13 +64,13 @@ public static Map<String, Integer> parseBucketNumber(@Nullable String rawValue)
             String[] kv = tableBucketNumStr.trim().split(":", 2);
             if (kv.length != 2) {
                 throw new IllegalArgumentException(
-                        "Invalid bucket number configuration for table : " + rawValue);
+                        "Invalid bucket number configuration for : " + Arrays.toString(kv));
             }
             try {
                 result.put(kv[0].trim(), Integer.valueOf(kv[1].trim()));
             } catch (NumberFormatException ignored) {
                 throw new IllegalArgumentException(
-                        "Invalid bucket number configuration for table : " + rawValue);
+                        "Invalid bucket number configuration for : " + rawValue);
             }
         }
         return result;

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/test/java/org/apache/flink/cdc/connectors/fluss/factory/FlussDataSinkFactoryTest.java

@@ -141,7 +141,7 @@ void testWrongBucketKeyAndBucketNum() {
                                                 new Configuration(),
                                                 Thread.currentThread().getContextClassLoader())))
                 .hasMessageContaining(
-                        "Invalid bucket number configuration for table : database1.table1: 11a");
+                        "Invalid bucket number configuration for : database1.table1: 11a");
     }
 
     private Configuration createValidConfiguration() {