[Improvement-17986][task-plugin] Use assertEquals instead of assertTrue(contains) in Flink tests

- Replace assertTrue(contains) with assertEquals in FlinkTaskTest and FlinkStreamTaskTest
- Remove class-level Javadoc per review
Ref: PR #17987

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

Author: 2 people

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

@@ -33,9 +33,6 @@
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.io.TempDir;
 
-/**
- * FlinkStreamTask unit test. Verifies parameter replacement in initScript and rawScript without Mockito.
- */
 public class FlinkStreamTaskTest {
 
     @TempDir
@@ -73,12 +70,10 @@ public void testParameterReplacementInScript() throws Exception {
         String initContent = Files.readString(Path.of(initScriptPath), StandardCharsets.UTF_8);
         String nodeContent = Files.readString(Path.of(nodeScriptPath), StandardCharsets.UTF_8);
 
-        Assertions.assertTrue(initContent.contains("SET 'date' = '20250601';"),
-                "Expected ${bizdate} to be replaced, got: " + initContent);
-        Assertions.assertTrue(nodeContent.contains("dt = '20250601'"),
-                "Expected ${bizdate} to be replaced, got: " + nodeContent);
-        Assertions.assertTrue(nodeContent.contains("env = 'prod'"),
-                "Expected ${env} to be replaced, got: " + nodeContent);
+        String expectedInitOptions = String.join(FlinkConstants.FLINK_SQL_NEWLINE,
+                FlinkArgsUtils.buildInitOptionsForSql(flinkParameters)).concat(FlinkConstants.FLINK_SQL_NEWLINE);
+        Assertions.assertEquals(expectedInitOptions + "SET 'date' = '20250601';", initContent);
+        Assertions.assertEquals("SELECT * FROM logs WHERE dt = '20250601' AND env = 'prod'", nodeContent.trim());
     }
 
     @Test
@@ -109,7 +104,6 @@ public void testParameterReplacementTimePlaceholder() throws Exception {
         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);
+        Assertions.assertEquals("INSERT INTO t SELECT * FROM s WHERE dt = '20210815'", nodeContent.trim());
     }
 }

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

@@ -33,9 +33,6 @@
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.io.TempDir;
 
-/**
- * FlinkTask unit test. Verifies parameter replacement in initScript and rawScript without Mockito.
- */
 public class FlinkTaskTest {
 
     @TempDir
@@ -73,10 +70,10 @@ public void testParameterReplacementInScript() throws Exception {
         String initContent = Files.readString(Path.of(initScriptPath), StandardCharsets.UTF_8);
         String nodeContent = Files.readString(Path.of(nodeScriptPath), StandardCharsets.UTF_8);
 
-        Assertions.assertTrue(initContent.contains("set batch_size=1000;"),
-                "Expected ${batch_size} to be replaced with 1000, got: " + initContent);
-        Assertions.assertTrue(nodeContent.contains("dt='20201201'"),
-                "Expected $[yyyyMMdd] to be replaced with 20201201, got: " + nodeContent);
+        String expectedInitOptions = String.join(FlinkConstants.FLINK_SQL_NEWLINE,
+                FlinkArgsUtils.buildInitOptionsForSql(flinkParameters)).concat(FlinkConstants.FLINK_SQL_NEWLINE);
+        Assertions.assertEquals(expectedInitOptions + "set batch_size=1000;", initContent);
+        Assertions.assertEquals("SELECT * FROM logs WHERE dt='20201201';", nodeContent.trim());
     }
 
     @Test