fix some normal code

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,16 +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: " + rawValue);
+                        "Invalid bucket number configuration for table : " + rawValue);
             }
-
-            String table = kv[0].trim();
             try {
-                int value = Integer.parseInt(kv[1].trim());
-                result.put(table, value);
+                result.put(kv[0].trim(), Integer.valueOf(kv[1].trim()));
             } catch (NumberFormatException ignored) {
                 throw new IllegalArgumentException(
-                        "Invalid bucket number configuration: " + rawValue);
+                        "Invalid bucket number configuration for table : " + 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

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