refactor(flink-test): call task.getScript() directly, remove ForTest subclasses

Same package allows direct access to protected getScript()
Ref: PR #17987 review

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: 段晓雄

dolphinscheduler-task-plugin/dolphinscheduler-task-flink-stream/src/test/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkStreamTaskTest.java

@@ -63,9 +63,9 @@ public void testParameterReplacementInScript() throws Exception {
         context.setTaskAppId(taskAppId);
         context.setPrepareParamsMap(prepareParamsMap);
 
-        FlinkStreamTaskForTest task = new FlinkStreamTaskForTest(context);
+        FlinkStreamTask task = new FlinkStreamTask(context);
         task.init();
-        task.callGetScript();
+        task.getScript();
 
         String initScriptPath = String.format("%s/%s_init.sql", executePath, taskAppId);
         String nodeScriptPath = String.format("%s/%s_node.sql", executePath, taskAppId);
@@ -102,25 +102,14 @@ public void testParameterReplacementTimePlaceholder() throws Exception {
         context.setTaskAppId(taskAppId);
         context.setPrepareParamsMap(prepareParamsMap);
 
-        FlinkStreamTaskForTest task = new FlinkStreamTaskForTest(context);
+        FlinkStreamTask task = new FlinkStreamTask(context);
         task.init();
-        task.callGetScript();
+        task.getScript();
 
         String nodeScriptPath = String.format("%s/%s_node.sql", executePath, taskAppId);
         String nodeContent = Files.readString(Path.of(nodeScriptPath), StandardCharsets.UTF_8);
 
         Assertions.assertTrue(nodeContent.contains("dt = '20210815'"),
                 "Expected $[yyyyMMdd] to be replaced with 20210815, got: " + nodeContent);
     }
-
-    private static class FlinkStreamTaskForTest extends FlinkStreamTask {
-
-        FlinkStreamTaskForTest(TaskExecutionContext context) {
-            super(context);
-        }
-
-        String callGetScript() {
-            return getScript();
-        }
-    }
 }

dolphinscheduler-task-plugin/dolphinscheduler-task-flink/src/test/java/org/apache/dolphinscheduler/plugin/task/flink/FlinkTaskTest.java

@@ -63,9 +63,9 @@ public void testParameterReplacementInScript() throws Exception {
         context.setTaskAppId(taskAppId);
         context.setPrepareParamsMap(prepareParamsMap);
 
-        FlinkTaskForTest task = new FlinkTaskForTest(context);
+        FlinkTask task = new FlinkTask(context);
         task.init();
-        task.callGetScript();
+        task.getScript();
 
         String initScriptPath = String.format("%s/%s_init.sql", executePath, taskAppId);
         String nodeScriptPath = String.format("%s/%s_node.sql", executePath, taskAppId);
@@ -97,24 +97,13 @@ public void testParameterReplacementWithNullParamsMap() throws Exception {
         context.setTaskAppId(taskAppId);
         context.setPrepareParamsMap(null);
 
-        FlinkTaskForTest task = new FlinkTaskForTest(context);
+        FlinkTask task = new FlinkTask(context);
         task.init();
-        String script = task.callGetScript();
+        String script = task.getScript();
 
         String nodeScriptPath = String.format("%s/%s_node.sql", executePath, taskAppId);
         String nodeContent = Files.readString(Path.of(nodeScriptPath), StandardCharsets.UTF_8);
         Assertions.assertEquals("SELECT 1;", nodeContent.trim());
         Assertions.assertNotNull(script);
     }
-
-    private static class FlinkTaskForTest extends FlinkTask {
-
-        FlinkTaskForTest(TaskExecutionContext context) {
-            super(context);
-        }
-
-        String callGetScript() {
-            return getScript();
-        }
-    }
 }