Skip to content

Commit 216ae0d

Browse files
committed
fix comment
Signed-off-by: Pei Yu <[email protected]>
1 parent 81678e8 commit 216ae0d

File tree

1 file changed

+15
-0
lines changed

1 file changed

+15
-0
lines changed

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/procedure/FlinkProcedureITCase.java

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -474,6 +474,21 @@ void testSetClusterConfigValidation() throws Exception {
474474
.rootCause()
475475
.hasMessageContaining(
476476
"config_pairs cannot be null or empty. Please specify a valid configuration pairs");
477+
478+
// Try to mismatched key-value pairs in the input parameters.
479+
assertThatThrownBy(
480+
() ->
481+
tEnv.executeSql(
482+
String.format(
483+
"Call %s.sys.set_cluster_configs('%s', 'paimon')",
484+
CATALOG_NAME,
485+
ConfigOptions
486+
.KV_SHARED_RATE_LIMITER_BYTES_PER_SEC
487+
.key()))
488+
.await())
489+
.rootCause()
490+
.hasMessageContaining(
491+
"Could not parse value 'paimon' for key 'kv.rocksdb.shared-rate-limiter.bytes-per-sec'");
477492
}
478493

479494
@Test

0 commit comments

Comments
 (0)