fix comment

Signed-off-by: peiyu <[email protected]>

Author: sd4324530

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/procedure/ResetClusterConfigsProcedure.java

@@ -47,7 +47,7 @@
  * CALL sys.reset_cluster_configs('kv.rocksdb.shared-rate-limiter.bytes-per-sec');
  *
  * -- reset multiple configurations at one time
- * CALL sys.reset_cluster_configs('kv.rocksdb.shared-rate-limiter.bytes-per-sec','datalake.format');
+ * CALL sys.reset_cluster_configs('kv.rocksdb.shared-rate-limiter.bytes-per-sec', 'datalake.format');
  *
  * </pre>
  *
@@ -64,7 +64,7 @@ public String[] call(ProcedureContext context, String... configKeys) throws Exce
             // Validate config key
             if (configKeys.length == 0) {
                 throw new IllegalArgumentException(
-                        "config_pairs cannot be null or empty. "
+                        "config_keys cannot be null or empty. "
                                 + "Please specify valid configuration keys.");
             }
 
@@ -76,7 +76,7 @@ public String[] call(ProcedureContext context, String... configKeys) throws Exce
                 if (configKey.isEmpty()) {
                     throw new IllegalArgumentException(
                             "Config key cannot be null or empty. "
-                                    + "Please specify valid configuration key.");
+                                    + "Please specify a valid configuration key.");
                 }
 
                 String operationDesc = "deleted (reset to default)";

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

@@ -428,7 +428,22 @@ void testSetClusterConfigValidation() throws Exception {
                                         .await())
                 .rootCause()
                 .hasMessageContaining(
-                        "config_pairs must be set in pairs. Please specify a valid configuration pairs.");
+                        "config_pairs must be set in pairs. Please specify a valid configuration pairs");
+    }
+
+    @Test
+    void testResetClusterConfigValidation() throws Exception {
+        // Try to reset an invalid config
+        assertThatThrownBy(
+                        () ->
+                                tEnv.executeSql(
+                                                String.format(
+                                                        "Call %s.sys.reset_cluster_configs('')",
+                                                        CATALOG_NAME))
+                                        .await())
+                .rootCause()
+                .hasMessageContaining(
+                        "Config key cannot be null or empty. Please specify a valid configuration key");
     }
 
     @ParameterizedTest