[fix](json)Fix the bug that does not stop when reading json files

apache · Aug 18, 2023 · 060380c · 060380c
1 parent 5bd43e1
commit 060380c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 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
@@ -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
@@ -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}",