change the log info value

ThorneANN · ThorneANN · commit 8691a08a6d02 · 2026-02-25T23:03:45.000+08:00
diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-fluss/src/main/java/org/apache/flink/cdc/connectors/fluss/utils/FlussConfigUtils.java b/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,7 +64,7 @@ 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 : " + Arrays.toString(kv));
+                        "Invalid bucket number configuration for : " + rawValue);
             }
             try {
                 result.put(kv[0].trim(), Integer.valueOf(kv[1].trim()));

Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ public static Map<String, Integer> parseBucketNumber(@Nullable String rawValue)`
`64`	`64`	`String[] kv = tableBucketNumStr.trim().split(":", 2);`
`65`	`65`	`if (kv.length != 2) {`
`66`	`66`	`throw new IllegalArgumentException(`
`67`		`- "Invalid bucket number configuration for : " + Arrays.toString(kv));`
	`67`	`+ "Invalid bucket number configuration for : " + rawValue);`
`68`	`68`	`}`
`69`	`69`	`try {`
`70`	`70`	`result.put(kv[0].trim(), Integer.valueOf(kv[1].trim()));`