diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json index 5abf6283cc84..ed3a4e789158 100644 Binary files a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json and b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json differ diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf index 12c4e626ffd4..37f25a2ff5c6 100644 --- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf +++ b/seatunnel-e2e/seatunnel-connector-v2-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" } ] }