From 060380cf6bc54a56fe82cfebb3daf33f7b843880 Mon Sep 17 00:00:00 2001 From: changyuwei <2017501503@qq.com> Date: Fri, 18 Aug 2023 11:02:32 +0800 Subject: [PATCH] [fix](json)Fix the bug that does not stop when reading json files --- .../data/external_table_p0/tvf/test_hdfs_tvf.out | 8 ++++---- .../suites/external_table_p0/tvf/test_hdfs_tvf.groovy | 8 ++++---- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/regression-test/data/external_table_p0/tvf/test_hdfs_tvf.out b/regression-test/data/external_table_p0/tvf/test_hdfs_tvf.out index ffe25a9c787618..9ae369b9774882 100644 --- a/regression-test/data/external_table_p0/tvf/test_hdfs_tvf.out +++ b/regression-test/data/external_table_p0/tvf/test_hdfs_tvf.out @@ -257,7 +257,7 @@ 8 chengdu 2345678 9 xian 2345679 --- !json_limit -- +-- !json_limit1 -- 1 beijing 2345671 10 hefei 23456710 11 \N 23456711 @@ -271,7 +271,7 @@ 8 chengdu 2345678 9 xian 2345679 --- !json_limit -- +-- !json_limit2 -- 1 beijing 1454547 10 hefei 2345676 2 shanghai 1244264 @@ -283,14 +283,14 @@ 8 chengdu 2345674 9 xian 2345675 --- !json_limit -- +-- !json_limit3 -- 1 {"id": 1, "city": "beijing", "code": 2345671} 2 {"id": 2, "city": "shanghai", "code": 2345672} 3 {"id": 3, "city": "hangzhou", "code": 2345673} 4 {"id": 4, "city": "shenzhen", "code": 2345674} 5 {"id": 5, "city": "guangzhou", "code": 2345675} --- !json_limit -- +-- !json_limit4 -- 1 {"id": 1, "city": "beijing", "code": 2345671} 2 {"id": 2, "city": "shanghai", "code": 2345672} diff --git a/regression-test/suites/external_table_p0/tvf/test_hdfs_tvf.groovy b/regression-test/suites/external_table_p0/tvf/test_hdfs_tvf.groovy index bf13c0f679316a..32315f60e6b80a 100644 --- a/regression-test/suites/external_table_p0/tvf/test_hdfs_tvf.groovy +++ b/regression-test/suites/external_table_p0/tvf/test_hdfs_tvf.groovy @@ -135,7 +135,7 @@ suite("test_hdfs_tvf","external,hive,tvf,external_docker") { uri = "${defaultFS}" + "/user/doris/preinstalled_data/json_format_test/simple_object_json.json" format = "json" - qt_json_limit """ select * from HDFS( + qt_json_limit1 """ select * from HDFS( "uri" = "${uri}", "fs.defaultFS"= "${defaultFS}", "hadoop.username" = "${hdfsUserName}", @@ -145,7 +145,7 @@ suite("test_hdfs_tvf","external,hive,tvf,external_docker") { uri = "${defaultFS}" + "/user/doris/preinstalled_data/json_format_test/one_array_json.json" format = "json" - qt_json_limit """ select * from HDFS( + qt_json_limit2 """ select * from HDFS( "uri" = "${uri}", "fs.defaultFS"= "${defaultFS}", "hadoop.username" = "${hdfsUserName}", @@ -154,7 +154,7 @@ suite("test_hdfs_tvf","external,hive,tvf,external_docker") { "read_json_by_line" = "false") order by id limit 100; """ uri = "${defaultFS}" + "/user/doris/preinstalled_data/json_format_test/nest_json.json" format = "json" - qt_json_limit """ select * from HDFS( + qt_json_limit3 """ select * from HDFS( "uri" = "${uri}", "fs.defaultFS"= "${defaultFS}", "hadoop.username" = "${hdfsUserName}", @@ -163,7 +163,7 @@ suite("test_hdfs_tvf","external,hive,tvf,external_docker") { "read_json_by_line" = "true") order by no limit 100; """ uri = "${defaultFS}" + "/user/doris/preinstalled_data/json_format_test/nest_json.json" format = "json" - qt_json_limit """ select * from HDFS( + qt_json_limit4 """ select * from HDFS( "uri" = "${uri}", "fs.defaultFS"= "${defaultFS}", "hadoop.username" = "${hdfsUserName}",