You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ap...@apache.org on 2015/05/21 19:17:17 UTC

hive git commit: HIVE-10717 Fix failed qtest encryption_insert_partition_static test in Jenkin (Alexander Pivovarov, reviewed by Ferdinand Xu, Sergio Pena, Swarnim Kulkarni)

Repository: hive
Updated Branches:
  refs/heads/master 5281326d9 -> b0e95070b


HIVE-10717 Fix failed qtest encryption_insert_partition_static test in Jenkin (Alexander Pivovarov, reviewed by Ferdinand Xu, Sergio Pena, Swarnim Kulkarni)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b0e95070
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b0e95070
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b0e95070

Branch: refs/heads/master
Commit: b0e95070bca437237417f88c2a5aa10e5f108223
Parents: 5281326
Author: Alexander Pivovarov <ap...@gmail.com>
Authored: Wed May 20 02:28:43 2015 -0700
Committer: Alexander Pivovarov <ap...@gmail.com>
Committed: Thu May 21 10:16:33 2015 -0700

----------------------------------------------------------------------
 .../encryption_insert_partition_static.q        |  35 +-
 .../encryption_insert_partition_static.q.out    | 355 ++++++++++++-------
 2 files changed, 239 insertions(+), 151 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/b0e95070/ql/src/test/queries/clientpositive/encryption_insert_partition_static.q
----------------------------------------------------------------------
diff --git a/ql/src/test/queries/clientpositive/encryption_insert_partition_static.q b/ql/src/test/queries/clientpositive/encryption_insert_partition_static.q
index 9bff0bd..c5769a6 100644
--- a/ql/src/test/queries/clientpositive/encryption_insert_partition_static.q
+++ b/ql/src/test/queries/clientpositive/encryption_insert_partition_static.q
@@ -31,32 +31,33 @@ insert into table encryptedTable partition
 select * from encryptedTable order by key;
 
 -- insert encrypted table from unencrypted source
-explain extended from src
-insert into table encryptedTable partition
-    (ds='yesterday')
-    select * limit 2;
+explain extended
+insert into table encryptedTable partition (ds='yesterday')
+select * from src where key in ('238', '86');
 
-from src
-insert into table encryptedTable partition
-    (ds='yesterday')
-    select * limit 2;
+insert into table encryptedTable partition (ds='yesterday')
+select * from src where key in ('238', '86');
 
 select * from encryptedTable order by key;
 
 -- insert unencrypted table from encrypted source
-explain extended from encryptedTable
-insert into table unencryptedTable partition
-    (ds='today')
-    select key, value;
+explain extended
+insert into table unencryptedTable partition (ds='today')
+select key, value from encryptedTable where ds='today';
+
+insert into table unencryptedTable partition (ds='today')
+select key, value from encryptedTable where ds='today';
+
+explain extended
+insert into table unencryptedTable partition (ds='yesterday')
+select key, value from encryptedTable where ds='yesterday';
 
-from encryptedTable
-insert into table unencryptedTable partition
-    (ds='today')
-    select key, value;
+insert into table unencryptedTable partition (ds='yesterday')
+select key, value from encryptedTable where ds='yesterday';
 
 select * from unencryptedTable order by key;
 
 -- clean up
 drop table encryptedTable PURGE;
 CRYPTO DELETE_KEY --keyName key_1;
-drop table unencryptedTable PURGE;
\ No newline at end of file
+drop table unencryptedTable PURGE;

http://git-wip-us.apache.org/repos/asf/hive/blob/b0e95070/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out b/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out
index 8966608..63b7011 100644
--- a/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out
+++ b/ql/src/test/results/clientpositive/encrypted/encryption_insert_partition_static.q.out
@@ -231,16 +231,14 @@ POSTHOOK: Input: default@encryptedtable@ds=today
 501	val_501	today
 502	val_502	today
 PREHOOK: query: -- insert encrypted table from unencrypted source
-explain extended from src
-insert into table encryptedTable partition
-    (ds='yesterday')
-    select * limit 2
+explain extended
+insert into table encryptedTable partition (ds='yesterday')
+select * from src where key in ('238', '86')
 PREHOOK: type: QUERY
 POSTHOOK: query: -- insert encrypted table from unencrypted source
-explain extended from src
-insert into table encryptedTable partition
-    (ds='yesterday')
-    select * limit 2
+explain extended
+insert into table encryptedTable partition (ds='yesterday')
+select * from src where key in ('238', '86')
 POSTHOOK: type: QUERY
 ABSTRACT SYNTAX TREE:
   
@@ -261,15 +259,19 @@ TOK_QUERY
       TOK_SELECT
          TOK_SELEXPR
             TOK_ALLCOLREF
-      TOK_LIMIT
-         2
+      TOK_WHERE
+         TOK_FUNCTION
+            in
+            TOK_TABLE_OR_COL
+               key
+            '238'
+            '86'
 
 
 STAGE DEPENDENCIES:
   Stage-1 is a root stage
-  Stage-2 depends on stages: Stage-1
-  Stage-0 depends on stages: Stage-2
-  Stage-3 depends on stages: Stage-0
+  Stage-0 depends on stages: Stage-1
+  Stage-2 depends on stages: Stage-0
 
 STAGE PLANS:
   Stage: Stage-1
@@ -279,16 +281,18 @@ STAGE PLANS:
             alias: src
             Statistics: Num rows: 29 Data size: 5812 Basic stats: COMPLETE Column stats: NONE
             GatherStats: false
-            Select Operator
-              expressions: key (type: string), value (type: string)
-              outputColumnNames: _col0, _col1
-              Statistics: Num rows: 29 Data size: 5812 Basic stats: COMPLETE Column stats: NONE
-              Limit
-                Number of rows: 2
-                Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column stats: NONE
+            Filter Operator
+              isSamplingPred: false
+              predicate: (key) IN ('238', '86') (type: boolean)
+              Statistics: Num rows: 14 Data size: 2805 Basic stats: COMPLETE Column stats: NONE
+              Select Operator
+                expressions: key (type: string), value (type: string)
+                outputColumnNames: _col0, _col1
+                Statistics: Num rows: 14 Data size: 2805 Basic stats: COMPLETE Column stats: NONE
                 Reduce Output Operator
                   sort order: 
-                  Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column stats: NONE
+                  Map-reduce partition columns: _col0 (type: string)
+                  Statistics: Num rows: 14 Data size: 2805 Basic stats: COMPLETE Column stats: NONE
                   tag: -1
                   value expressions: _col0 (type: string), _col1 (type: string)
                   auto parallelism: false
@@ -346,78 +350,14 @@ STAGE PLANS:
         Select Operator
           expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
           outputColumnNames: _col0, _col1
-          Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column stats: NONE
-          Limit
-            Number of rows: 2
-            Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column stats: NONE
-            File Output Operator
-              compressed: false
-              GlobalTableId: 0
-#### A masked pattern was here ####
-              NumFilesPerFileSink: 1
-              table:
-                  input format: org.apache.hadoop.mapred.SequenceFileInputFormat
-                  output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
-                  properties:
-                    columns _col0,_col1
-                    columns.types string,string
-                    escape.delim \
-                    serialization.lib org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
-                  serde: org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
-              TotalFiles: 1
-              GatherStats: false
-              MultiFileSpray: false
-
-  Stage: Stage-2
-    Map Reduce
-      Map Operator Tree:
-          TableScan
-            GatherStats: false
-            Reduce Output Operator
-              sort order: 
-              Map-reduce partition columns: _col0 (type: string)
-              Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column stats: NONE
-              tag: -1
-              value expressions: _col0 (type: string), _col1 (type: string)
-              auto parallelism: false
-      Path -> Alias:
-#### A masked pattern was here ####
-      Path -> Partition:
-#### A masked pattern was here ####
-          Partition
-            base file name: -mr-10001
-            input format: org.apache.hadoop.mapred.SequenceFileInputFormat
-            output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
-            properties:
-              columns _col0,_col1
-              columns.types string,string
-              escape.delim \
-              serialization.lib org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
-            serde: org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
-          
-              input format: org.apache.hadoop.mapred.SequenceFileInputFormat
-              output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
-              properties:
-                columns _col0,_col1
-                columns.types string,string
-                escape.delim \
-                serialization.lib org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
-              serde: org.apache.hadoop.hive.serde2.lazybinary.LazyBinarySerDe
-      Truncated Path -> Alias:
-#### A masked pattern was here ####
-      Needs Tagging: false
-      Reduce Operator Tree:
-        Select Operator
-          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
-          outputColumnNames: _col0, _col1
-          Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column stats: NONE
+          Statistics: Num rows: 14 Data size: 2805 Basic stats: COMPLETE Column stats: NONE
           File Output Operator
             compressed: false
             GlobalTableId: 1
 #### A PARTIAL masked pattern was here #### data/warehouse/encryptedTable/ds=yesterday/.hive-staging
             NumFilesPerFileSink: 1
             Static Partition Specification: ds=yesterday/
-            Statistics: Num rows: 2 Data size: 400 Basic stats: COMPLETE Column stats: NONE
+            Statistics: Num rows: 14 Data size: 2805 Basic stats: COMPLETE Column stats: NONE
 #### A PARTIAL masked pattern was here #### data/warehouse/encryptedTable/ds=yesterday/.hive-staging
             table:
                 input format: org.apache.hadoop.hive.ql.io.orc.OrcInputFormat
@@ -471,21 +411,17 @@ STAGE PLANS:
               serde: org.apache.hadoop.hive.ql.io.orc.OrcSerde
               name: default.encryptedtable
 
-  Stage: Stage-3
+  Stage: Stage-2
     Stats-Aggr Operator
 #### A PARTIAL masked pattern was here #### data/warehouse/encryptedTable/ds=yesterday/.hive-staging
 
-PREHOOK: query: from src
-insert into table encryptedTable partition
-    (ds='yesterday')
-    select * limit 2
+PREHOOK: query: insert into table encryptedTable partition (ds='yesterday')
+select * from src where key in ('238', '86')
 PREHOOK: type: QUERY
 PREHOOK: Input: default@src
 PREHOOK: Output: default@encryptedtable@ds=yesterday
-POSTHOOK: query: from src
-insert into table encryptedTable partition
-    (ds='yesterday')
-    select * limit 2
+POSTHOOK: query: insert into table encryptedTable partition (ds='yesterday')
+select * from src where key in ('238', '86')
 POSTHOOK: type: QUERY
 POSTHOOK: Input: default@src
 POSTHOOK: Output: default@encryptedtable@ds=yesterday
@@ -504,20 +440,19 @@ POSTHOOK: Input: default@encryptedtable@ds=today
 POSTHOOK: Input: default@encryptedtable@ds=yesterday
 #### A PARTIAL masked pattern was here #### data/warehouse/encryptedTable/.hive-staging
 238	val_238	yesterday
+238	val_238	yesterday
 501	val_501	today
 502	val_502	today
 86	val_86	yesterday
 PREHOOK: query: -- insert unencrypted table from encrypted source
-explain extended from encryptedTable
-insert into table unencryptedTable partition
-    (ds='today')
-    select key, value
+explain extended
+insert into table unencryptedTable partition (ds='today')
+select key, value from encryptedTable where ds='today'
 PREHOOK: type: QUERY
 POSTHOOK: query: -- insert unencrypted table from encrypted source
-explain extended from encryptedTable
-insert into table unencryptedTable partition
-    (ds='today')
-    select key, value
+explain extended
+insert into table unencryptedTable partition (ds='today')
+select key, value from encryptedTable where ds='today'
 POSTHOOK: type: QUERY
 ABSTRACT SYNTAX TREE:
   
@@ -542,6 +477,11 @@ TOK_QUERY
          TOK_SELEXPR
             TOK_TABLE_OR_COL
                value
+      TOK_WHERE
+         =
+            TOK_TABLE_OR_COL
+               ds
+            'today'
 
 
 STAGE DEPENDENCIES:
@@ -555,16 +495,16 @@ STAGE PLANS:
       Map Operator Tree:
           TableScan
             alias: encryptedtable
-            Statistics: Num rows: 12 Data size: 2777 Basic stats: COMPLETE Column stats: NONE
+            Statistics: Num rows: 6 Data size: 1385 Basic stats: COMPLETE Column stats: NONE
             GatherStats: false
             Select Operator
               expressions: key (type: string), value (type: string)
               outputColumnNames: _col0, _col1
-              Statistics: Num rows: 12 Data size: 2777 Basic stats: COMPLETE Column stats: NONE
+              Statistics: Num rows: 6 Data size: 1385 Basic stats: COMPLETE Column stats: NONE
               Reduce Output Operator
                 sort order: 
                 Map-reduce partition columns: _col0 (type: string)
-                Statistics: Num rows: 12 Data size: 2777 Basic stats: COMPLETE Column stats: NONE
+                Statistics: Num rows: 6 Data size: 1385 Basic stats: COMPLETE Column stats: NONE
                 tag: -1
                 value expressions: _col0 (type: string), _col1 (type: string)
                 auto parallelism: false
@@ -595,7 +535,7 @@ STAGE PLANS:
               serialization.ddl struct encryptedtable { string key, string value}
               serialization.format 1
               serialization.lib org.apache.hadoop.hive.ql.io.orc.OrcSerde
-              totalSize 1392
+              totalSize 1385
 #### A masked pattern was here ####
             serde: org.apache.hadoop.hive.ql.io.orc.OrcSerde
           
@@ -619,6 +559,157 @@ STAGE PLANS:
               serde: org.apache.hadoop.hive.ql.io.orc.OrcSerde
               name: default.encryptedtable
             name: default.encryptedtable
+      Truncated Path -> Alias:
+        /encryptedTable/ds=today [encryptedtable]
+      Needs Tagging: false
+      Reduce Operator Tree:
+        Select Operator
+          expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
+          outputColumnNames: _col0, _col1
+          Statistics: Num rows: 6 Data size: 1385 Basic stats: COMPLETE Column stats: NONE
+          File Output Operator
+            compressed: false
+            GlobalTableId: 1
+#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=today/.hive-staging
+            NumFilesPerFileSink: 1
+            Static Partition Specification: ds=today/
+            Statistics: Num rows: 6 Data size: 1385 Basic stats: COMPLETE Column stats: NONE
+#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=today/.hive-staging
+            table:
+                input format: org.apache.hadoop.hive.ql.io.orc.OrcInputFormat
+                output format: org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat
+                properties:
+                  bucket_count 2
+                  bucket_field_name key
+                  columns key,value
+                  columns.comments 
+                  columns.types string:string
+#### A masked pattern was here ####
+                  name default.unencryptedtable
+                  partition_columns ds
+                  partition_columns.types string
+                  serialization.ddl struct unencryptedtable { string key, string value}
+                  serialization.format 1
+                  serialization.lib org.apache.hadoop.hive.ql.io.orc.OrcSerde
+                  transactional true
+#### A masked pattern was here ####
+                serde: org.apache.hadoop.hive.ql.io.orc.OrcSerde
+                name: default.unencryptedtable
+            TotalFiles: 1
+            GatherStats: true
+            MultiFileSpray: false
+
+  Stage: Stage-0
+    Move Operator
+      tables:
+          partition:
+            ds today
+          replace: false
+#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=today/.hive-staging
+          table:
+              input format: org.apache.hadoop.hive.ql.io.orc.OrcInputFormat
+              output format: org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat
+              properties:
+                bucket_count 2
+                bucket_field_name key
+                columns key,value
+                columns.comments 
+                columns.types string:string
+#### A masked pattern was here ####
+                name default.unencryptedtable
+                partition_columns ds
+                partition_columns.types string
+                serialization.ddl struct unencryptedtable { string key, string value}
+                serialization.format 1
+                serialization.lib org.apache.hadoop.hive.ql.io.orc.OrcSerde
+                transactional true
+#### A masked pattern was here ####
+              serde: org.apache.hadoop.hive.ql.io.orc.OrcSerde
+              name: default.unencryptedtable
+
+  Stage: Stage-2
+    Stats-Aggr Operator
+#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=today/.hive-staging
+
+PREHOOK: query: insert into table unencryptedTable partition (ds='today')
+select key, value from encryptedTable where ds='today'
+PREHOOK: type: QUERY
+PREHOOK: Input: default@encryptedtable
+PREHOOK: Input: default@encryptedtable@ds=today
+PREHOOK: Output: default@unencryptedtable@ds=today
+POSTHOOK: query: insert into table unencryptedTable partition (ds='today')
+select key, value from encryptedTable where ds='today'
+POSTHOOK: type: QUERY
+POSTHOOK: Input: default@encryptedtable
+POSTHOOK: Input: default@encryptedtable@ds=today
+POSTHOOK: Output: default@unencryptedtable@ds=today
+POSTHOOK: Lineage: unencryptedtable PARTITION(ds=today).key SIMPLE [(encryptedtable)encryptedtable.FieldSchema(name:key, type:string, comment:null), ]
+POSTHOOK: Lineage: unencryptedtable PARTITION(ds=today).value SIMPLE [(encryptedtable)encryptedtable.FieldSchema(name:value, type:string, comment:null), ]
+PREHOOK: query: explain extended
+insert into table unencryptedTable partition (ds='yesterday')
+select key, value from encryptedTable where ds='yesterday'
+PREHOOK: type: QUERY
+POSTHOOK: query: explain extended
+insert into table unencryptedTable partition (ds='yesterday')
+select key, value from encryptedTable where ds='yesterday'
+POSTHOOK: type: QUERY
+ABSTRACT SYNTAX TREE:
+  
+TOK_QUERY
+   TOK_FROM
+      TOK_TABREF
+         TOK_TABNAME
+            encryptedTable
+   TOK_INSERT
+      TOK_INSERT_INTO
+         TOK_TAB
+            TOK_TABNAME
+               unencryptedTable
+            TOK_PARTSPEC
+               TOK_PARTVAL
+                  ds
+                  'yesterday'
+      TOK_SELECT
+         TOK_SELEXPR
+            TOK_TABLE_OR_COL
+               key
+         TOK_SELEXPR
+            TOK_TABLE_OR_COL
+               value
+      TOK_WHERE
+         =
+            TOK_TABLE_OR_COL
+               ds
+            'yesterday'
+
+
+STAGE DEPENDENCIES:
+  Stage-1 is a root stage
+  Stage-0 depends on stages: Stage-1
+  Stage-2 depends on stages: Stage-0
+
+STAGE PLANS:
+  Stage: Stage-1
+    Map Reduce
+      Map Operator Tree:
+          TableScan
+            alias: encryptedtable
+            Statistics: Num rows: 7 Data size: 1408 Basic stats: COMPLETE Column stats: NONE
+            GatherStats: false
+            Select Operator
+              expressions: key (type: string), value (type: string)
+              outputColumnNames: _col0, _col1
+              Statistics: Num rows: 7 Data size: 1408 Basic stats: COMPLETE Column stats: NONE
+              Reduce Output Operator
+                sort order: 
+                Map-reduce partition columns: _col0 (type: string)
+                Statistics: Num rows: 7 Data size: 1408 Basic stats: COMPLETE Column stats: NONE
+                tag: -1
+                value expressions: _col0 (type: string), _col1 (type: string)
+                auto parallelism: false
+      Path -> Alias:
+#### A masked pattern was here ####
+      Path -> Partition:
 #### A masked pattern was here ####
           Partition
             base file name: ds=yesterday
@@ -643,7 +734,7 @@ STAGE PLANS:
               serialization.ddl struct encryptedtable { string key, string value}
               serialization.format 1
               serialization.lib org.apache.hadoop.hive.ql.io.orc.OrcSerde
-              totalSize 1385
+              totalSize 1408
 #### A masked pattern was here ####
             serde: org.apache.hadoop.hive.ql.io.orc.OrcSerde
           
@@ -668,22 +759,21 @@ STAGE PLANS:
               name: default.encryptedtable
             name: default.encryptedtable
       Truncated Path -> Alias:
-        /encryptedTable/ds=today [encryptedtable]
         /encryptedTable/ds=yesterday [encryptedtable]
       Needs Tagging: false
       Reduce Operator Tree:
         Select Operator
           expressions: VALUE._col0 (type: string), VALUE._col1 (type: string)
           outputColumnNames: _col0, _col1
-          Statistics: Num rows: 12 Data size: 2777 Basic stats: COMPLETE Column stats: NONE
+          Statistics: Num rows: 7 Data size: 1408 Basic stats: COMPLETE Column stats: NONE
           File Output Operator
             compressed: false
             GlobalTableId: 1
-#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=today/.hive-staging
+#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=yesterday/.hive-staging
             NumFilesPerFileSink: 1
-            Static Partition Specification: ds=today/
-            Statistics: Num rows: 12 Data size: 2777 Basic stats: COMPLETE Column stats: NONE
-#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=today/.hive-staging
+            Static Partition Specification: ds=yesterday/
+            Statistics: Num rows: 7 Data size: 1408 Basic stats: COMPLETE Column stats: NONE
+#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=yesterday/.hive-staging
             table:
                 input format: org.apache.hadoop.hive.ql.io.orc.OrcInputFormat
                 output format: org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat
@@ -712,9 +802,9 @@ STAGE PLANS:
     Move Operator
       tables:
           partition:
-            ds today
+            ds yesterday
           replace: false
-#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=today/.hive-staging
+#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=yesterday/.hive-staging
           table:
               input format: org.apache.hadoop.hive.ql.io.orc.OrcInputFormat
               output format: org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat
@@ -738,42 +828,39 @@ STAGE PLANS:
 
   Stage: Stage-2
     Stats-Aggr Operator
-#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=today/.hive-staging
+#### A PARTIAL masked pattern was here #### data/warehouse/unencryptedtable/ds=yesterday/.hive-staging
 
-PREHOOK: query: from encryptedTable
-insert into table unencryptedTable partition
-    (ds='today')
-    select key, value
+PREHOOK: query: insert into table unencryptedTable partition (ds='yesterday')
+select key, value from encryptedTable where ds='yesterday'
 PREHOOK: type: QUERY
 PREHOOK: Input: default@encryptedtable
-PREHOOK: Input: default@encryptedtable@ds=today
 PREHOOK: Input: default@encryptedtable@ds=yesterday
-PREHOOK: Output: default@unencryptedtable@ds=today
-POSTHOOK: query: from encryptedTable
-insert into table unencryptedTable partition
-    (ds='today')
-    select key, value
+PREHOOK: Output: default@unencryptedtable@ds=yesterday
+POSTHOOK: query: insert into table unencryptedTable partition (ds='yesterday')
+select key, value from encryptedTable where ds='yesterday'
 POSTHOOK: type: QUERY
 POSTHOOK: Input: default@encryptedtable
-POSTHOOK: Input: default@encryptedtable@ds=today
 POSTHOOK: Input: default@encryptedtable@ds=yesterday
-POSTHOOK: Output: default@unencryptedtable@ds=today
-POSTHOOK: Lineage: unencryptedtable PARTITION(ds=today).key SIMPLE [(encryptedtable)encryptedtable.FieldSchema(name:key, type:string, comment:null), ]
-POSTHOOK: Lineage: unencryptedtable PARTITION(ds=today).value SIMPLE [(encryptedtable)encryptedtable.FieldSchema(name:value, type:string, comment:null), ]
+POSTHOOK: Output: default@unencryptedtable@ds=yesterday
+POSTHOOK: Lineage: unencryptedtable PARTITION(ds=yesterday).key SIMPLE [(encryptedtable)encryptedtable.FieldSchema(name:key, type:string, comment:null), ]
+POSTHOOK: Lineage: unencryptedtable PARTITION(ds=yesterday).value SIMPLE [(encryptedtable)encryptedtable.FieldSchema(name:value, type:string, comment:null), ]
 PREHOOK: query: select * from unencryptedTable order by key
 PREHOOK: type: QUERY
 PREHOOK: Input: default@unencryptedtable
 PREHOOK: Input: default@unencryptedtable@ds=today
+PREHOOK: Input: default@unencryptedtable@ds=yesterday
 #### A masked pattern was here ####
 POSTHOOK: query: select * from unencryptedTable order by key
 POSTHOOK: type: QUERY
 POSTHOOK: Input: default@unencryptedtable
 POSTHOOK: Input: default@unencryptedtable@ds=today
+POSTHOOK: Input: default@unencryptedtable@ds=yesterday
 #### A masked pattern was here ####
-238	val_238	today
+238	val_238	yesterday
+238	val_238	yesterday
 501	val_501	today
 502	val_502	today
-86	val_86	today
+86	val_86	yesterday
 PREHOOK: query: -- clean up
 drop table encryptedTable PURGE
 PREHOOK: type: DROPTABLE