[fix] Correct shardIds length validation in ClickHouseShardTableParametersProvider

itinycheng · itinycheng · commit 5642f6930f0f · 2025-05-26T10:47:43.000+08:00
diff --git a/flink-connector-clickhouse/src/main/java/org/apache/flink/connector/clickhouse/split/ClickHouseShardTableParametersProvider.java b/flink-connector-clickhouse/src/main/java/org/apache/flink/connector/clickhouse/split/ClickHouseShardTableParametersProvider.java
@@ -33,7 +33,7 @@ public class ClickHouseShardTableParametersProvider extends ClickHouseParameters
     private final int shardNum;
 
     public ClickHouseShardTableParametersProvider(int[] shardIds) {
-        checkArgument(shardIds.length > 1, "length of shardIds must be larger than 0");
+        checkArgument(shardIds.length > 0, "length of shardIds must be larger than 0");
         this.shardIds = shardIds;
         this.shardNum = shardIds.length;
     }

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,7 @@ public class ClickHouseShardTableParametersProvider extends ClickHouseParameters`
`33`	`33`	`private final int shardNum;`
`34`	`34`
`35`	`35`	`public ClickHouseShardTableParametersProvider(int[] shardIds) {`
`36`		`- checkArgument(shardIds.length > 1, "length of shardIds must be larger than 0");`
	`36`	`+ checkArgument(shardIds.length > 0, "length of shardIds must be larger than 0");`
`37`	`37`	`this.shardIds = shardIds;`
`38`	`38`	`this.shardNum = shardIds.length;`
`39`	`39`	`}`