[Feature] update assert sink check

apache · Sep 18, 2023 · f341d14 · f341d14
1 parent 01865f2
commit f341d14
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 15 deletions.
diff --git a/.../seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json b/.../seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json
diff --git a/...-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf b/...-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf
@@ -27,6 +27,7 @@ env {
 
 source {
   LocalFile {
+    result_table_name = "fake"
     path = "/seatunnel/read/lzo_json"
     row_delimiter = "\n"
     partition_dir_expression = "${k0}=${v0}"
@@ -76,9 +77,10 @@ source {
 
 sink {
   Console {
-
+    source_table_name = "fake"
   }
   Assert {
+    source_table_name = "fake"
     rules {
       row_rules = [
         {
@@ -92,7 +94,7 @@ sink {
           field_type = string
           field_value = [
             {
-              rule_type = NOT_NULL
+              equals_to = "WArEB"
             }
           ]
         },
@@ -110,25 +112,16 @@ sink {
           field_type = double
           field_value = [
             {
-              rule_type = NOT_NULL
+              equals_to = 12.4
             }
           ]
         },
         {
-          field_name = name
-          field_type = string
+          field_name = c_date
+          field_type = date
           field_value = [
             {
-              rule_type = NOT_NULL
-            }
-          ]
-        },
-        {
-          field_name = hobby
-          field_type = string
-          field_value = [
-            {
-              rule_type = NOT_NULL
+              equals_to = "2022-05-05"
             }
           ]
         }