fix comment

Author: MOBIN-F

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java

@@ -64,7 +64,7 @@ public class YamlPipelineDefinitionParser implements PipelineDefinitionParser {
     private static final String TRANSFORM_KEY = "transform";
     private static final String PIPELINE_KEY = "pipeline";
     private static final String MODEL_KEY = "model";
-    private static final String FLINK_KEY = "flink";
+    private static final String FLINK_KEY = "flink-conf";
 
     // Source / sink keys
     private static final String TYPE_KEY = "type";

flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java

@@ -131,18 +131,20 @@ private static void mergeCommandLineFlinkConfig(
 
         LOG.info("Dynamic flink config items found from command-line: {}", commandLineProperties);
         commandLineProperties.forEach(
-                (key, value) -> {
-                    String keyStr = key.toString();
-                    String valueStr = value.toString();
-                    if (StringUtils.isNullOrWhitespaceOnly(keyStr)
-                            || StringUtils.isNullOrWhitespaceOnly(valueStr)) {
-                        throw new IllegalArgumentException(
-                                String.format(
-                                        "null or white space argument for key or value: %s=%s",
-                                        key, value));
-                    }
-                    flinkConfig.setString(keyStr.trim(), valueStr.trim());
-                });
+                (key, value) -> validateAndApplyCommandLineEntry(flinkConfig, key, value));
+    }
+
+    private static void validateAndApplyCommandLineEntry(
+            Configuration flinkConfig, Object key, Object value) {
+        String keyStr = key.toString();
+        String valueStr = value.toString();
+        if (StringUtils.isNullOrWhitespaceOnly(keyStr)
+                || StringUtils.isNullOrWhitespaceOnly(valueStr)) {
+            throw new IllegalArgumentException(
+                    String.format(
+                            "null or white space argument for key or value: %s=%s", key, value));
+        }
+        flinkConfig.setString(keyStr.trim(), valueStr.trim());
     }
 
     private static void mergePipelineFlinkConfig(

flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml

@@ -64,5 +64,5 @@ pipeline:
     openai.model: text-embedding-3-small
     openai.host: https://xxxx
     openai.apikey: abcd1234
-  flink:
+  flink-conf:
     execution.checkpointing.timeout: 12min