Skip to content

Commit c1f8a3c

Browse files
committed
fix comment
Signed-off-by: peiyu <[email protected]>
1 parent 053dd5d commit c1f8a3c

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -435,7 +435,7 @@ void testResetClusterConfigs() throws Exception {
435435
}
436436

437437
@Test
438-
void testSetClusterConfigValidation() throws Exception {
438+
void testSetClusterConfigsValidation() throws Exception {
439439
// Try to set an invalid config (not allowed for dynamic change)
440440
assertThatThrownBy(
441441
() ->
@@ -445,6 +445,7 @@ void testSetClusterConfigValidation() throws Exception {
445445
CATALOG_NAME))
446446
.await())
447447
.rootCause()
448+
// TODO: Fix misleading error: non-existent key reported as not allowed.
448449
.hasMessageContaining(
449450
"The config key invalid.config.key is not allowed to be changed dynamically");
450451

@@ -492,7 +493,7 @@ void testSetClusterConfigValidation() throws Exception {
492493
}
493494

494495
@Test
495-
void testResetClusterConfigValidation() throws Exception {
496+
void testResetClusterConfigsValidation() throws Exception {
496497
// Try to reset an invalid config
497498
assertThatThrownBy(
498499
() ->
@@ -502,6 +503,7 @@ void testResetClusterConfigValidation() throws Exception {
502503
CATALOG_NAME))
503504
.await())
504505
.rootCause()
506+
// TODO: Fix misleading error: non-existent key reported as not allowed.
505507
.hasMessageContaining(
506508
"The config key invalid.config.key is not allowed to be changed dynamically");
507509

0 commit comments

Comments
 (0)