diff --git itests/src/test/resources/testconfiguration.properties itests/src/test/resources/testconfiguration.properties index 1c7905db31..d192a44170 100644 --- itests/src/test/resources/testconfiguration.properties +++ itests/src/test/resources/testconfiguration.properties @@ -423,6 +423,7 @@ minillap.query.files=acid_bucket_pruning.q,\ load_fs2.q,\ llap_stats.q,\ multi_count_distinct_null.q,\ + multi_insert_parallel.q, \ cttl.q minillaplocal.query.files=\ diff --git ql/src/test/queries/clientpositive/multi_insert_parallel.q ql/src/test/queries/clientpositive/multi_insert_parallel.q new file mode 100644 index 0000000000..16927ffdb8 --- /dev/null +++ ql/src/test/queries/clientpositive/multi_insert_parallel.q @@ -0,0 +1,13 @@ +--! qt:dataset:src + +create table src_multi1 like src; +create table src_multi2 like src; + +set hive.exec.parallel=true; +set hive.merge.tezfiles=true; +set tez.grouping.max-size=2000; +set tez.grouping.min-size=1000; + +from src +insert overwrite table src_multi1 select * where key < 10 +insert overwrite table src_multi2 select * where key > 10 and key < 20; diff --git ql/src/test/results/clientpositive/llap/multi_insert_parallel.q.out ql/src/test/results/clientpositive/llap/multi_insert_parallel.q.out new file mode 100644 index 0000000000..d2dcb1956c --- /dev/null +++ ql/src/test/results/clientpositive/llap/multi_insert_parallel.q.out @@ -0,0 +1,34 @@ +PREHOOK: query: create table src_multi1 like src +PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default +PREHOOK: Output: default@src_multi1 +POSTHOOK: query: create table src_multi1 like src +POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default +POSTHOOK: Output: default@src_multi1 +PREHOOK: query: create table src_multi2 like src +PREHOOK: type: CREATETABLE +PREHOOK: Output: database:default +PREHOOK: Output: default@src_multi2 +POSTHOOK: query: create table src_multi2 like src +POSTHOOK: type: CREATETABLE +POSTHOOK: Output: database:default +POSTHOOK: Output: default@src_multi2 +PREHOOK: query: from src +insert overwrite table src_multi1 select * where key < 10 +insert overwrite table src_multi2 select * where key > 10 and key < 20 +PREHOOK: type: QUERY +PREHOOK: Input: default@src +PREHOOK: Output: default@src_multi1 +PREHOOK: Output: default@src_multi2 +POSTHOOK: query: from src +insert overwrite table src_multi1 select * where key < 10 +insert overwrite table src_multi2 select * where key > 10 and key < 20 +POSTHOOK: type: QUERY +POSTHOOK: Input: default@src +POSTHOOK: Output: default@src_multi1 +POSTHOOK: Output: default@src_multi2 +POSTHOOK: Lineage: src_multi1.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: src_multi1.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] +POSTHOOK: Lineage: src_multi2.key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] +POSTHOOK: Lineage: src_multi2.value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ]