fix flink procedure test case

Author: platinumhamburg

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

@@ -100,7 +100,7 @@ private String[] performSet(String configKey, @Nullable String configValue) thro
                 operationDesc = String.format("set to '%s'", configValue);
             }
 
-            // Construct configuration modification operation
+            // Construct configuration modification operation.
             AlterConfig alterConfig = new AlterConfig(configKey, configValue, opType);
 
             // Call Admin API to modify cluster configuration

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

@@ -29,6 +29,7 @@
 import org.apache.flink.types.Row;
 import org.apache.flink.util.CloseableIterator;
 import org.apache.flink.util.CollectionUtil;
+import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -86,6 +87,31 @@ void before() throws ExecutionException, InterruptedException {
         tEnv.executeSql("use catalog " + CATALOG_NAME);
     }
 
+    @AfterEach
+    void after() throws Exception {
+        // Clean up any dynamic config changes made during the test
+        // to ensure tests don't affect each other
+        if (tEnv != null) {
+            try {
+                // Delete dynamic configs that might have been modified during tests
+                // This resets them to their initial static configuration values
+                tEnv.executeSql(
+                                String.format(
+                                        "Call %s.sys.set_cluster_config('%s')",
+                                        CATALOG_NAME,
+                                        ConfigOptions.KV_SHARED_RATE_LIMITER_BYTES_PER_SEC.key()))
+                        .await();
+                tEnv.executeSql(
+                                String.format(
+                                        "Call %s.sys.set_cluster_config('%s')",
+                                        CATALOG_NAME, ConfigOptions.DATALAKE_FORMAT.key()))
+                        .await();
+            } catch (Exception e) {
+                // Ignore cleanup errors to avoid masking test failures
+            }
+        }
+    }
+
     @Test
     void testShowProcedures() throws Exception {
         try (CloseableIterator<Row> showProceduresIterator =