add more UT Case

luchunliang · Sep 3, 2024 · 84e9c05 · 84e9c05
1 parent f7af914
commit 84e9c05
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/...orm-sdk/src/test/java/org/apache/inlong/sdk/transform/process/TestTransformProcessor.java b/...orm-sdk/src/test/java/org/apache/inlong/sdk/transform/process/TestTransformProcessor.java
@@ -382,6 +382,17 @@ public void testCsv2Star() throws Exception {
         List<String> output3 = processor3.transform("2024-04-28 00:00:00|nok", new HashMap<>());
         Assert.assertEquals(1, output3.size());
         Assert.assertEquals(output3.get(0), "2024-04-28 00:00:00|nok|nok|2024-04-28 00:00:00");
+        // case4
+        CsvSourceInfo csvSourceNoField = new CsvSourceInfo("UTF-8", '|', '\\', new ArrayList<>());
+        CsvSinkInfo csvSinkNoField = new CsvSinkInfo("UTF-8", '|', '\\', new ArrayList<>());
+        config.setTransformSql("select * from source where extinfo!='ok'");
+        TransformProcessor<String, String> processor4 = TransformProcessor
+                .create(config, SourceDecoderFactory.createCsvDecoder(csvSourceNoField),
+                        SinkEncoderFactory.createCsvEncoder(csvSinkNoField));
+
+        List<String> output4 = processor4.transform("2024-04-28 00:00:00|nok", new HashMap<>());
+        Assert.assertEquals(1, output4.size());
+        Assert.assertEquals(output4.get(0), "2024-04-28 00:00:00|nok");
     }
 
     @Test

diff --git a/pom.xml b/pom.xml
@@ -48,7 +48,6 @@
         <module>inlong-sort-standalone</module>
         <module>inlong-manager</module>
         <module>inlong-dashboard</module>
-        <module>inlong-distribution</module>
     </modules>
 
     <properties>