diff --git ql/src/test/results/clientpositive/alter_numbuckets_partitioned_table2_h23.q.out ql/src/test/results/clientpositive/alter_numbuckets_partitioned_table2_h23.q.out index 9375af3..8107f32 100644 --- ql/src/test/results/clientpositive/alter_numbuckets_partitioned_table2_h23.q.out +++ ql/src/test/results/clientpositive/alter_numbuckets_partitioned_table2_h23.q.out @@ -15,8 +15,10 @@ POSTHOOK: Output: database:default POSTHOOK: Output: default@tst1 PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 # col_name data_type comment key string @@ -59,8 +61,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] # col_name data_type comment @@ -112,8 +116,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] # col_name data_type comment @@ -160,8 +166,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -217,8 +225,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -269,8 +279,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -330,8 +342,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -386,8 +400,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -451,8 +467,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -511,8 +529,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -580,8 +600,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -644,8 +666,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -717,8 +741,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -785,8 +811,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -862,8 +890,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -934,8 +964,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -1015,8 +1047,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -1091,8 +1125,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: DESCRIBE FORMATTED tst1 PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] diff --git ql/src/test/results/clientpositive/alter_numbuckets_partitioned_table_h23.q.out ql/src/test/results/clientpositive/alter_numbuckets_partitioned_table_h23.q.out index 7369ff7..112a35f 100644 --- ql/src/test/results/clientpositive/alter_numbuckets_partitioned_table_h23.q.out +++ ql/src/test/results/clientpositive/alter_numbuckets_partitioned_table_h23.q.out @@ -17,8 +17,10 @@ POSTHOOK: Input: default@tst1 POSTHOOK: Output: default@tst1 PREHOOK: query: describe formatted tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 # col_name data_type comment key string @@ -61,8 +63,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted tst1 partition (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 partition (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] # col_name data_type comment @@ -128,8 +132,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted tst1 partition (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 partition (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -171,8 +177,10 @@ Storage Desc Params: serialization.format 1 PREHOOK: query: describe formatted tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -224,8 +232,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -262,8 +272,10 @@ Storage Desc Params: serialization.format 1 PREHOOK: query: describe formatted tst1 partition (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 partition (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -317,8 +329,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -355,8 +369,10 @@ Storage Desc Params: serialization.format 1 PREHOOK: query: describe formatted tst1 partition (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 partition (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -415,8 +431,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -469,8 +487,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -523,8 +543,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -577,8 +599,10 @@ POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:ke POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted tst1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@tst1 POSTHOOK: query: describe formatted tst1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@tst1 POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: tst1 PARTITION(ds=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] diff --git ql/src/test/results/clientpositive/ctas.q.out ql/src/test/results/clientpositive/ctas.q.out index ce9e105..32b0b31 100644 --- ql/src/test/results/clientpositive/ctas.q.out +++ ql/src/test/results/clientpositive/ctas.q.out @@ -125,8 +125,10 @@ POSTHOOK: Input: default@nzhang_ctas1 104 val_104 PREHOOK: query: describe formatted nzhang_CTAS1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@nzhang_ctas1 POSTHOOK: query: describe formatted nzhang_CTAS1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@nzhang_ctas1 # col_name data_type comment k string @@ -265,8 +267,10 @@ POSTHOOK: Input: default@nzhang_ctas2 104 val_104 PREHOOK: query: describe formatted nzhang_CTAS2 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@nzhang_ctas2 POSTHOOK: query: describe formatted nzhang_CTAS2 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@nzhang_ctas2 # col_name data_type comment key string @@ -406,8 +410,10 @@ POSTHOOK: Input: default@nzhang_ctas3 4.5 val_9_con PREHOOK: query: describe formatted nzhang_CTAS3 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@nzhang_ctas3 POSTHOOK: query: describe formatted nzhang_CTAS3 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@nzhang_ctas3 # col_name data_type comment half_key double @@ -469,8 +475,10 @@ POSTHOOK: Input: default@nzhang_ctas3 4.5 val_9_con PREHOOK: query: describe formatted nzhang_CTAS3 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@nzhang_ctas3 POSTHOOK: query: describe formatted nzhang_CTAS3 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@nzhang_ctas3 # col_name data_type comment half_key double @@ -610,8 +618,10 @@ POSTHOOK: Input: default@nzhang_ctas4 104 val_104 PREHOOK: query: describe formatted nzhang_CTAS4 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@nzhang_ctas4 POSTHOOK: query: describe formatted nzhang_CTAS4 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@nzhang_ctas4 # col_name data_type comment key string diff --git ql/src/test/results/clientpositive/lb_fs_stats.q.out ql/src/test/results/clientpositive/lb_fs_stats.q.out index e182e2c..db7b9ab 100644 --- ql/src/test/results/clientpositive/lb_fs_stats.q.out +++ ql/src/test/results/clientpositive/lb_fs_stats.q.out @@ -33,8 +33,10 @@ POSTHOOK: Lineage: test_tab PARTITION(part=1).key SIMPLE [(src)src.FieldSchema(n POSTHOOK: Lineage: test_tab PARTITION(part=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted test_tab partition (part='1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@test_tab POSTHOOK: query: describe formatted test_tab partition (part='1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@test_tab POSTHOOK: Lineage: test_tab PARTITION(part=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: test_tab PARTITION(part=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out index 915d1a8..55f7b7b 100644 --- ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out +++ ql/src/test/results/clientpositive/list_bucket_query_multiskew_1.q.out @@ -53,8 +53,10 @@ POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=4).key SIMPLE [(src)src.FieldSch POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=4).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='4') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@fact_daily POSTHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='4') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@fact_daily POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=4).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=4).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] # col_name data_type comment @@ -221,6 +223,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -239,6 +242,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -381,6 +385,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -399,6 +404,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -534,6 +540,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -552,6 +559,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -688,6 +696,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -706,6 +715,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe diff --git ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out index 76fb67b..7d2f9f9 100644 --- ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out +++ ql/src/test/results/clientpositive/list_bucket_query_multiskew_2.q.out @@ -51,8 +51,10 @@ POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=4).key SIMPLE [(src)src.FieldSch POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=4).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='4') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@fact_daily POSTHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='4') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@fact_daily POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=4).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=4).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] # col_name data_type comment @@ -209,6 +211,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -227,6 +230,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -253,6 +257,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -271,6 +276,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -420,6 +426,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -438,6 +445,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -610,6 +618,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -628,6 +637,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -654,6 +664,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -672,6 +683,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe diff --git ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out index ef8c128..22e7b1d 100644 --- ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out +++ ql/src/test/results/clientpositive/list_bucket_query_multiskew_3.q.out @@ -53,8 +53,10 @@ POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=1).key SIMPLE [(src)src.FieldSch POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@fact_daily POSTHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@fact_daily POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] # col_name data_type comment @@ -121,8 +123,10 @@ POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=2).key SIMPLE [(src)src.FieldSch POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=2).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='2') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@fact_daily POSTHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='2') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@fact_daily POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=2).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -200,8 +204,10 @@ POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=3).key SIMPLE [(src)src.FieldSch POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=3).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='3') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@fact_daily POSTHOOK: query: describe formatted fact_daily PARTITION (ds = '1', hr='3') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@fact_daily POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=1).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=1).value SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: fact_daily PARTITION(ds=1,hr=2).key SIMPLE [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -357,6 +363,7 @@ STAGE PLANS: numFiles 1 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -375,6 +382,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -491,6 +499,7 @@ STAGE PLANS: numFiles 1 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -509,6 +518,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -685,6 +695,7 @@ STAGE PLANS: numFiles 3 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -703,6 +714,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -847,6 +859,7 @@ STAGE PLANS: numFiles 2 numRows 500 partition_columns ds/hr + partition_columns.types string:string rawDataSize 5312 serialization.ddl struct fact_daily { string key, string value} serialization.format 1 @@ -865,6 +878,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds/hr + partition_columns.types string:string serialization.ddl struct fact_daily { string key, string value} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe diff --git ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out index eaeb999..0f6a4e8 100644 --- ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out +++ ql/src/test/results/clientpositive/list_bucket_query_oneskew_1.q.out @@ -124,8 +124,10 @@ POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSche POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@fact_daily POSTHOOK: query: describe formatted fact_daily PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@fact_daily POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] # col_name data_type comment @@ -279,6 +281,7 @@ STAGE PLANS: numFiles 2 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x} serialization.format 1 @@ -298,6 +301,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -426,6 +430,7 @@ STAGE PLANS: numFiles 2 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x} serialization.format 1 @@ -445,6 +450,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -569,6 +575,7 @@ STAGE PLANS: numFiles 2 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x} serialization.format 1 @@ -588,6 +595,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe diff --git ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out index 33b700e..d92c55b 100644 --- ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out +++ ql/src/test/results/clientpositive/list_bucket_query_oneskew_2.q.out @@ -137,8 +137,10 @@ POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).x EXPRESSION [(src)src.FieldSche POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).y SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@fact_daily POSTHOOK: query: describe formatted fact_daily PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@fact_daily POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).y SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=2).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] @@ -311,6 +313,7 @@ STAGE PLANS: numFiles 2 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x, string y} serialization.format 1 @@ -330,6 +333,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x, string y} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -474,6 +478,7 @@ STAGE PLANS: numFiles 2 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x, string y} serialization.format 1 @@ -493,6 +498,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x, string y} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -649,6 +655,7 @@ STAGE PLANS: numFiles 2 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x, string y} serialization.format 1 @@ -668,6 +675,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x, string y} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -848,6 +856,7 @@ STAGE PLANS: numFiles 2 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x, string y} serialization.format 1 @@ -867,6 +876,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x, string y} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe diff --git ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out index b1b0c50..e094f61 100644 --- ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out +++ ql/src/test/results/clientpositive/list_bucket_query_oneskew_3.q.out @@ -181,8 +181,10 @@ POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=3).y SIMPLE [(src)src.FieldSchema(n POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=3).z SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] PREHOOK: query: describe formatted fact_daily PARTITION (ds = '1') PREHOOK: type: DESCTABLE +PREHOOK: Input: default@fact_daily POSTHOOK: query: describe formatted fact_daily PARTITION (ds = '1') POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@fact_daily POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).x EXPRESSION [(src)src.FieldSchema(name:key, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).y SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] POSTHOOK: Lineage: fact_tz PARTITION(ds=1,hr=1).z SIMPLE [(src)src.FieldSchema(name:value, type:string, comment:default), ] @@ -353,6 +355,7 @@ STAGE PLANS: numFiles 3 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x, string y, string z} serialization.format 1 @@ -372,6 +375,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x, string y, string z} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -397,6 +401,7 @@ STAGE PLANS: numFiles 3 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x, string y, string z} serialization.format 1 @@ -416,6 +421,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x, string y, string z} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe @@ -441,6 +447,7 @@ STAGE PLANS: numFiles 3 numRows -1 partition_columns ds + partition_columns.types string rawDataSize -1 serialization.ddl struct fact_daily { i32 x, string y, string z} serialization.format 1 @@ -460,6 +467,7 @@ STAGE PLANS: #### A masked pattern was here #### name default.fact_daily partition_columns ds + partition_columns.types string serialization.ddl struct fact_daily { i32 x, string y, string z} serialization.format 1 serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe diff --git ql/src/test/results/clientpositive/union_remove_1.q.out ql/src/test/results/clientpositive/union_remove_1.q.out index 02ac7e7..286216c 100644 --- ql/src/test/results/clientpositive/union_remove_1.q.out +++ ql/src/test/results/clientpositive/union_remove_1.q.out @@ -182,8 +182,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_10.q.out ql/src/test/results/clientpositive/union_remove_10.q.out index 9a7613b..0fc6c5f 100644 --- ql/src/test/results/clientpositive/union_remove_10.q.out +++ ql/src/test/results/clientpositive/union_remove_10.q.out @@ -248,8 +248,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_11.q.out ql/src/test/results/clientpositive/union_remove_11.q.out index b43dca1..9c6fe3a 100644 --- ql/src/test/results/clientpositive/union_remove_11.q.out +++ ql/src/test/results/clientpositive/union_remove_11.q.out @@ -226,8 +226,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_12.q.out ql/src/test/results/clientpositive/union_remove_12.q.out index 64becc9..579f686 100644 --- ql/src/test/results/clientpositive/union_remove_12.q.out +++ ql/src/test/results/clientpositive/union_remove_12.q.out @@ -74,7 +74,8 @@ STAGE DEPENDENCIES: Stage-2 Stage-4 Stage-5 depends on stages: Stage-4 - Stage-9 is a root stage + Stage-10 is a root stage + Stage-9 depends on stages: Stage-10 STAGE PLANS: Stage: Stage-8 @@ -127,6 +128,25 @@ STAGE PLANS: hdfs directory: true #### A masked pattern was here #### + Stage: Stage-10 + Map Reduce Local Work + Alias -> Map Local Tables: + null-subquery2:c-subquery2:a + Fetch Operator + limit: -1 + Alias -> Map Local Operator Tree: + null-subquery2:c-subquery2:a + TableScan + alias: a + Statistics: Num rows: 0 Data size: 30 Basic stats: PARTIAL Column stats: NONE + HashTable Sink Operator + condition expressions: + 0 {key} + 1 {val} + keys: + 0 key (type: string) + 1 key (type: string) + Stage: Stage-9 Map Reduce Map Operator Tree: @@ -158,15 +178,6 @@ STAGE PLANS: name: default.outputtbl1 Local Work: Map Reduce Local Work - Alias -> Map Local Tables: - null-subquery2:c-subquery2:a - Fetch Operator - limit: -1 - Alias -> Map Local Operator Tree: - null-subquery2:c-subquery2:a - TableScan - alias: a - Statistics: Num rows: 0 Data size: 30 Basic stats: PARTIAL Column stats: NONE PREHOOK: query: insert overwrite table outputTbl1 SELECT * FROM @@ -194,8 +205,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)a.FieldSchema(name:key, POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)b.FieldSchema(name:val, type:string, comment:null), ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)a.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)b.FieldSchema(name:val, type:string, comment:null), ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_13.q.out ql/src/test/results/clientpositive/union_remove_13.q.out index bef7e96..868e029 100644 --- ql/src/test/results/clientpositive/union_remove_13.q.out +++ ql/src/test/results/clientpositive/union_remove_13.q.out @@ -74,7 +74,8 @@ STAGE DEPENDENCIES: Stage-2 Stage-4 Stage-5 depends on stages: Stage-4 - Stage-9 is a root stage + Stage-10 is a root stage + Stage-9 depends on stages: Stage-10 STAGE PLANS: Stage: Stage-8 @@ -150,6 +151,25 @@ STAGE PLANS: hdfs directory: true #### A masked pattern was here #### + Stage: Stage-10 + Map Reduce Local Work + Alias -> Map Local Tables: + null-subquery2:c-subquery2:a + Fetch Operator + limit: -1 + Alias -> Map Local Operator Tree: + null-subquery2:c-subquery2:a + TableScan + alias: a + Statistics: Num rows: 0 Data size: 30 Basic stats: PARTIAL Column stats: NONE + HashTable Sink Operator + condition expressions: + 0 {key} + 1 {val} + keys: + 0 key (type: string) + 1 key (type: string) + Stage: Stage-9 Map Reduce Map Operator Tree: @@ -181,15 +201,6 @@ STAGE PLANS: name: default.outputtbl1 Local Work: Map Reduce Local Work - Alias -> Map Local Tables: - null-subquery2:c-subquery2:a - Fetch Operator - limit: -1 - Alias -> Map Local Operator Tree: - null-subquery2:c-subquery2:a - TableScan - alias: a - Statistics: Num rows: 0 Data size: 30 Basic stats: PARTIAL Column stats: NONE PREHOOK: query: insert overwrite table outputTbl1 SELECT * FROM @@ -217,8 +228,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)a.FieldSchema(name:key, POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)b.FieldSchema(name:val, type:string, comment:null), (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)a.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)b.FieldSchema(name:val, type:string, comment:null), (inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_14.q.out ql/src/test/results/clientpositive/union_remove_14.q.out index 88b844f..47a6fa8 100644 --- ql/src/test/results/clientpositive/union_remove_14.q.out +++ ql/src/test/results/clientpositive/union_remove_14.q.out @@ -76,7 +76,8 @@ STAGE DEPENDENCIES: Stage-2 Stage-4 Stage-5 depends on stages: Stage-4 - Stage-9 is a root stage + Stage-10 is a root stage + Stage-9 depends on stages: Stage-10 STAGE PLANS: Stage: Stage-8 @@ -129,6 +130,25 @@ STAGE PLANS: hdfs directory: true #### A masked pattern was here #### + Stage: Stage-10 + Map Reduce Local Work + Alias -> Map Local Tables: + null-subquery2:c-subquery2:a + Fetch Operator + limit: -1 + Alias -> Map Local Operator Tree: + null-subquery2:c-subquery2:a + TableScan + alias: a + Statistics: Num rows: 0 Data size: 30 Basic stats: PARTIAL Column stats: NONE + HashTable Sink Operator + condition expressions: + 0 {key} + 1 {val} + keys: + 0 key (type: string) + 1 key (type: string) + Stage: Stage-9 Map Reduce Map Operator Tree: @@ -160,15 +180,6 @@ STAGE PLANS: name: default.outputtbl1 Local Work: Map Reduce Local Work - Alias -> Map Local Tables: - null-subquery2:c-subquery2:a - Fetch Operator - limit: -1 - Alias -> Map Local Operator Tree: - null-subquery2:c-subquery2:a - TableScan - alias: a - Statistics: Num rows: 0 Data size: 30 Basic stats: PARTIAL Column stats: NONE PREHOOK: query: insert overwrite table outputTbl1 SELECT * FROM @@ -196,8 +207,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)a.FieldSchema(name:key, POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)b.FieldSchema(name:val, type:string, comment:null), ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)a.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)b.FieldSchema(name:val, type:string, comment:null), ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_15.q.out ql/src/test/results/clientpositive/union_remove_15.q.out index 051b49d..58c1b43 100644 --- ql/src/test/results/clientpositive/union_remove_15.q.out +++ ql/src/test/results/clientpositive/union_remove_15.q.out @@ -193,8 +193,10 @@ POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtb POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] @@ -231,8 +233,10 @@ Storage Desc Params: serialization.format 1 PREHOOK: query: show partitions outputTbl1 PREHOOK: type: SHOWPARTITIONS +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: show partitions outputTbl1 POSTHOOK: type: SHOWPARTITIONS +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] diff --git ql/src/test/results/clientpositive/union_remove_16.q.out ql/src/test/results/clientpositive/union_remove_16.q.out index 13547dc..d1ec28b 100644 --- ql/src/test/results/clientpositive/union_remove_16.q.out +++ ql/src/test/results/clientpositive/union_remove_16.q.out @@ -217,8 +217,10 @@ POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtb POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] @@ -255,8 +257,10 @@ Storage Desc Params: serialization.format 1 PREHOOK: query: show partitions outputTbl1 PREHOOK: type: SHOWPARTITIONS +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: show partitions outputTbl1 POSTHOOK: type: SHOWPARTITIONS +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] diff --git ql/src/test/results/clientpositive/union_remove_17.q.out ql/src/test/results/clientpositive/union_remove_17.q.out index bf473ff..d277ce0 100644 --- ql/src/test/results/clientpositive/union_remove_17.q.out +++ ql/src/test/results/clientpositive/union_remove_17.q.out @@ -79,14 +79,12 @@ STAGE PLANS: expressions: _col0 (type: string), UDFToLong(_col1) (type: bigint), _col2 (type: string) outputColumnNames: _col0, _col1, _col2 Statistics: Num rows: 0 Data size: 60 Basic stats: PARTIAL Column stats: NONE - File Output Operator - compressed: false + Reduce Output Operator + key expressions: _col2 (type: string) + sort order: + + Map-reduce partition columns: _col2 (type: string) Statistics: Num rows: 0 Data size: 60 Basic stats: PARTIAL Column stats: NONE - table: - input format: org.apache.hadoop.hive.ql.io.RCFileInputFormat - output format: org.apache.hadoop.hive.ql.io.RCFileOutputFormat - serde: org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe - name: default.outputtbl1 + value expressions: _col0 (type: string), _col1 (type: bigint), _col2 (type: string) TableScan alias: inputtbl1 Statistics: Num rows: 0 Data size: 30 Basic stats: PARTIAL Column stats: NONE @@ -100,14 +98,27 @@ STAGE PLANS: expressions: _col0 (type: string), UDFToLong(_col1) (type: bigint), _col2 (type: string) outputColumnNames: _col0, _col1, _col2 Statistics: Num rows: 0 Data size: 60 Basic stats: PARTIAL Column stats: NONE - File Output Operator - compressed: false + Reduce Output Operator + key expressions: _col2 (type: string) + sort order: + + Map-reduce partition columns: _col2 (type: string) Statistics: Num rows: 0 Data size: 60 Basic stats: PARTIAL Column stats: NONE - table: - input format: org.apache.hadoop.hive.ql.io.RCFileInputFormat - output format: org.apache.hadoop.hive.ql.io.RCFileOutputFormat - serde: org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe - name: default.outputtbl1 + value expressions: _col0 (type: string), _col1 (type: bigint), _col2 (type: string) + Reduce Operator Tree: + Extract + Statistics: Num rows: 0 Data size: 60 Basic stats: PARTIAL Column stats: NONE + Select Operator + expressions: _col0 (type: string), _col1 (type: bigint), _col2 (type: string) + outputColumnNames: _col0, _col1, _col2 + Statistics: Num rows: 0 Data size: 60 Basic stats: PARTIAL Column stats: NONE + File Output Operator + compressed: false + Statistics: Num rows: 0 Data size: 60 Basic stats: PARTIAL Column stats: NONE + table: + input format: org.apache.hadoop.hive.ql.io.RCFileInputFormat + output format: org.apache.hadoop.hive.ql.io.RCFileOutputFormat + serde: org.apache.hadoop.hive.serde2.columnar.ColumnarSerDe + name: default.outputtbl1 Stage: Stage-0 Move Operator @@ -148,8 +159,10 @@ POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtb POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).values EXPRESSION [] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).values EXPRESSION [] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] @@ -186,8 +199,10 @@ Storage Desc Params: serialization.format 1 PREHOOK: query: show partitions outputTbl1 PREHOOK: type: SHOWPARTITIONS +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: show partitions outputTbl1 POSTHOOK: type: SHOWPARTITIONS +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=1).values EXPRESSION [] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=2).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] diff --git ql/src/test/results/clientpositive/union_remove_18.q.out ql/src/test/results/clientpositive/union_remove_18.q.out index d41e9fe..40b4fc7 100644 --- ql/src/test/results/clientpositive/union_remove_18.q.out +++ ql/src/test/results/clientpositive/union_remove_18.q.out @@ -203,8 +203,10 @@ POSTHOOK: Lineage: outputtbl1 PARTITION(ds=28).key EXPRESSION [(inputtbl1)inputt POSTHOOK: Lineage: outputtbl1 PARTITION(ds=28).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1 PARTITION(ds=11).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=11).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=12).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] @@ -249,8 +251,10 @@ Storage Desc Params: serialization.format 1 PREHOOK: query: show partitions outputTbl1 PREHOOK: type: SHOWPARTITIONS +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: show partitions outputTbl1 POSTHOOK: type: SHOWPARTITIONS +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1 PARTITION(ds=11).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=11).values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] POSTHOOK: Lineage: outputtbl1 PARTITION(ds=12).key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] @@ -357,7 +361,7 @@ POSTHOOK: Lineage: outputtbl1 PARTITION(ds=28).values EXPRESSION [(inputtbl1)inp 3 1 13 7 1 17 7 1 17 -8 1 18 -8 1 28 8 1 28 8 1 18 +8 1 18 +8 1 28 diff --git ql/src/test/results/clientpositive/union_remove_19.q.out ql/src/test/results/clientpositive/union_remove_19.q.out index 43526ee..a9f7fa8 100644 --- ql/src/test/results/clientpositive/union_remove_19.q.out +++ ql/src/test/results/clientpositive/union_remove_19.q.out @@ -182,8 +182,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_2.q.out ql/src/test/results/clientpositive/union_remove_2.q.out index 74ef777..2076caf 100644 --- ql/src/test/results/clientpositive/union_remove_2.q.out +++ ql/src/test/results/clientpositive/union_remove_2.q.out @@ -189,8 +189,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_20.q.out ql/src/test/results/clientpositive/union_remove_20.q.out index 81304fc..016e23b 100644 --- ql/src/test/results/clientpositive/union_remove_20.q.out +++ ql/src/test/results/clientpositive/union_remove_20.q.out @@ -184,8 +184,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_21.q.out ql/src/test/results/clientpositive/union_remove_21.q.out index 068b84e..adfca79 100644 --- ql/src/test/results/clientpositive/union_remove_21.q.out +++ ql/src/test/results/clientpositive/union_remove_21.q.out @@ -183,8 +183,10 @@ POSTHOOK: Output: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_22.q.out ql/src/test/results/clientpositive/union_remove_22.q.out index 3e8d691..9afa79f 100644 --- ql/src/test/results/clientpositive/union_remove_22.q.out +++ ql/src/test/results/clientpositive/union_remove_22.q.out @@ -183,8 +183,10 @@ POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inp POSTHOOK: Lineage: outputtbl1.values2 EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] POSTHOOK: Lineage: outputtbl1.values2 EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] diff --git ql/src/test/results/clientpositive/union_remove_23.q.out ql/src/test/results/clientpositive/union_remove_23.q.out index 0782737..38879d2 100644 --- ql/src/test/results/clientpositive/union_remove_23.q.out +++ ql/src/test/results/clientpositive/union_remove_23.q.out @@ -223,8 +223,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)b.null, (inputtbl1)a.null, (inputtbl1)b.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)a.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)b.null, (inputtbl1)a.null, (inputtbl1)b.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_24.q.out ql/src/test/results/clientpositive/union_remove_24.q.out index 2591b57..6a68c3e 100644 --- ql/src/test/results/clientpositive/union_remove_24.q.out +++ ql/src/test/results/clientpositive/union_remove_24.q.out @@ -180,8 +180,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_3.q.out ql/src/test/results/clientpositive/union_remove_3.q.out index 823dffd..9d7145a 100644 --- ql/src/test/results/clientpositive/union_remove_3.q.out +++ ql/src/test/results/clientpositive/union_remove_3.q.out @@ -174,8 +174,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_4.q.out ql/src/test/results/clientpositive/union_remove_4.q.out index 759b250..2669a82 100644 --- ql/src/test/results/clientpositive/union_remove_4.q.out +++ ql/src/test/results/clientpositive/union_remove_4.q.out @@ -226,8 +226,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_5.q.out ql/src/test/results/clientpositive/union_remove_5.q.out index a7546e4..f83a6be 100644 --- ql/src/test/results/clientpositive/union_remove_5.q.out +++ ql/src/test/results/clientpositive/union_remove_5.q.out @@ -235,8 +235,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_7.q.out ql/src/test/results/clientpositive/union_remove_7.q.out index c3213e5..79ae23d 100644 --- ql/src/test/results/clientpositive/union_remove_7.q.out +++ ql/src/test/results/clientpositive/union_remove_7.q.out @@ -186,8 +186,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, (inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_8.q.out ql/src/test/results/clientpositive/union_remove_8.q.out index 676c412..8851546 100644 --- ql/src/test/results/clientpositive/union_remove_8.q.out +++ ql/src/test/results/clientpositive/union_remove_8.q.out @@ -193,8 +193,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] # col_name data_type comment diff --git ql/src/test/results/clientpositive/union_remove_9.q.out ql/src/test/results/clientpositive/union_remove_9.q.out index 24ad12d..8a43863 100644 --- ql/src/test/results/clientpositive/union_remove_9.q.out +++ ql/src/test/results/clientpositive/union_remove_9.q.out @@ -232,8 +232,10 @@ POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(n POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] PREHOOK: query: desc formatted outputTbl1 PREHOOK: type: DESCTABLE +PREHOOK: Input: default@outputtbl1 POSTHOOK: query: desc formatted outputTbl1 POSTHOOK: type: DESCTABLE +POSTHOOK: Input: default@outputtbl1 POSTHOOK: Lineage: outputtbl1.key EXPRESSION [(inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), (inputtbl1)inputtbl1.FieldSchema(name:key, type:string, comment:null), ] POSTHOOK: Lineage: outputtbl1.values EXPRESSION [(inputtbl1)inputtbl1.null, ] # col_name data_type comment