hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gunt...@apache.org
Subject [27/51] [partial] hive git commit: HIVE-15790: Remove unused beeline golden files (Gunther Hagleitner, reviewed by Sergey Shelukhin)
Date Fri, 03 Feb 2017 21:50:40 GMT
http://git-wip-us.apache.org/repos/asf/hive/blob/3890ed65/ql/src/test/results/beelinepositive/bucketmapjoin9.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/beelinepositive/bucketmapjoin9.q.out b/ql/src/test/results/beelinepositive/bucketmapjoin9.q.out
deleted file mode 100644
index 5203c40..0000000
--- a/ql/src/test/results/beelinepositive/bucketmapjoin9.q.out
+++ /dev/null
@@ -1,465 +0,0 @@
-Saving all output to "!!{outputDirectory}!!/bucketmapjoin9.q.raw". Enter "record" with no arguments to stop it.
->>>  !run !!{qFileDirectory}!!/bucketmapjoin9.q
->>>  set hive.input.format=org.apache.hadoop.hive.ql.io.HiveInputFormat;
-No rows affected 
->>>  
->>>  CREATE TABLE srcbucket_mapjoin_part_1 (key INT, value STRING) PARTITIONED BY (part STRING) 
-CLUSTERED BY (key) INTO 2 BUCKETS STORED AS TEXTFILE;
-No rows affected 
->>>  LOAD DATA LOCAL INPATH '../data/files/srcbucket20.txt' INTO TABLE srcbucket_mapjoin_part_1 PARTITION (part='1');
-No rows affected 
->>>  LOAD DATA LOCAL INPATH '../data/files/srcbucket21.txt' INTO TABLE srcbucket_mapjoin_part_1 PARTITION (part='1');
-No rows affected 
->>>  
->>>  CREATE TABLE srcbucket_mapjoin_part_2 (key INT, value STRING) PARTITIONED BY (part STRING) 
-CLUSTERED BY (key) INTO 3 BUCKETS STORED AS TEXTFILE;
-No rows affected 
->>>  LOAD DATA LOCAL INPATH '../data/files/srcbucket20.txt' INTO TABLE srcbucket_mapjoin_part_2 PARTITION (part='1');
-No rows affected 
->>>  LOAD DATA LOCAL INPATH '../data/files/srcbucket21.txt' INTO TABLE srcbucket_mapjoin_part_2 PARTITION (part='1');
-No rows affected 
->>>  LOAD DATA LOCAL INPATH '../data/files/srcbucket22.txt' INTO TABLE srcbucket_mapjoin_part_2 PARTITION (part='1');
-No rows affected 
->>>  
->>>  ALTER TABLE srcbucket_mapjoin_part_2 CLUSTERED BY (key) INTO 2 BUCKETS;
-No rows affected 
->>>  
->>>  set hive.optimize.bucketmapjoin=true;
-No rows affected 
->>>  
->>>  -- The table bucketing metadata matches but the partitions have different numbers of buckets, bucket map join should not be used
->>>  
->>>  EXPLAIN EXTENDED 
-SELECT /*+ MAPJOIN(b) */ count(*) 
-FROM srcbucket_mapjoin_part_1 a JOIN srcbucket_mapjoin_part_2 b 
-ON a.key = b.key AND a.part = '1' and b.part = '1';
-'Explain'
-'ABSTRACT SYNTAX TREE:'
-'  (TOK_QUERY (TOK_FROM (TOK_JOIN (TOK_TABREF (TOK_TABNAME srcbucket_mapjoin_part_1) a) (TOK_TABREF (TOK_TABNAME srcbucket_mapjoin_part_2) b) (and (AND (= (. (TOK_TABLE_OR_COL a) key) (. (TOK_TABLE_OR_COL b) key)) (= (. (TOK_TABLE_OR_COL a) part) '1')) (= (. (TOK_TABLE_OR_COL b) part) '1')))) (TOK_INSERT (TOK_DESTINATION (TOK_DIR TOK_TMP_FILE)) (TOK_SELECT (TOK_HINTLIST (TOK_HINT TOK_MAPJOIN (TOK_HINTARGLIST b))) (TOK_SELEXPR (TOK_FUNCTIONSTAR count)))))'
-''
-'STAGE DEPENDENCIES:'
-'  Stage-4 is a root stage'
-'  Stage-1 depends on stages: Stage-4'
-'  Stage-2 depends on stages: Stage-1'
-'  Stage-0 is a root stage'
-''
-'STAGE PLANS:'
-'  Stage: Stage-4'
-'    Map Reduce Local Work'
-'      Alias -> Map Local Tables:'
-'        b '
-'          Fetch Operator'
-'            limit: -1'
-'      Alias -> Map Local Operator Tree:'
-'        b '
-'          TableScan'
-'            alias: b'
-'            GatherStats: false'
-'            HashTable Sink Operator'
-'              condition expressions:'
-'                0 '
-'                1 '
-'              handleSkewJoin: false'
-'              keys:'
-'                0 [Column[key]]'
-'                1 [Column[key]]'
-'              Position of Big Table: 0'
-''
-'  Stage: Stage-1'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        a '
-'          TableScan'
-'            alias: a'
-'            GatherStats: false'
-'            Map Join Operator'
-'              condition map:'
-'                   Inner Join 0 to 1'
-'              condition expressions:'
-'                0 '
-'                1 '
-'              handleSkewJoin: false'
-'              keys:'
-'                0 [Column[key]]'
-'                1 [Column[key]]'
-'              Position of Big Table: 0'
-'              File Output Operator'
-'                compressed: false'
-'                GlobalTableId: 0'
-'                directory: file:!!{hive.exec.scratchdir}!!'
-'                NumFilesPerFileSink: 1'
-'                table:'
-'                    input format: org.apache.hadoop.mapred.SequenceFileInputFormat'
-'                    output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat'
-'                    properties:'
-'                      columns '
-'                      columns.types '
-'                      escape.delim \'
-'                TotalFiles: 1'
-'                GatherStats: false'
-'                MultiFileSpray: false'
-'      Local Work:'
-'        Map Reduce Local Work'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        !!{hive.metastore.warehouse.dir}!!/bucketmapjoin9.db/srcbucket_mapjoin_part_1/part=1 [a]'
-'      Path -> Partition:'
-'        !!{hive.metastore.warehouse.dir}!!/bucketmapjoin9.db/srcbucket_mapjoin_part_1/part=1 '
-'          Partition'
-'            base file name: part=1'
-'            input format: org.apache.hadoop.mapred.TextInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'            partition values:'
-'              part 1'
-'            properties:'
-'              bucket_count 2'
-'              bucket_field_name key'
-'              columns key,value'
-'              columns.types int:string'
-'              file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'              file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin9.db/srcbucket_mapjoin_part_1/part=1'
-'              name bucketmapjoin9.srcbucket_mapjoin_part_1'
-'              numFiles 2'
-'              numPartitions 1'
-'              numRows 0'
-'              partition_columns part'
-'              rawDataSize 0'
-'              serialization.ddl struct srcbucket_mapjoin_part_1 { i32 key, string value}'
-'              serialization.format 1'
-'              serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              totalSize 2750'
-'              transient_lastDdlTime !!UNIXTIME!!'
-'            serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'          '
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count 2'
-'                bucket_field_name key'
-'                columns key,value'
-'                columns.types int:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin9.db/srcbucket_mapjoin_part_1'
-'                name bucketmapjoin9.srcbucket_mapjoin_part_1'
-'                numFiles 2'
-'                numPartitions 1'
-'                numRows 0'
-'                partition_columns part'
-'                rawDataSize 0'
-'                serialization.ddl struct srcbucket_mapjoin_part_1 { i32 key, string value}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                totalSize 2750'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin9.srcbucket_mapjoin_part_1'
-'            name: bucketmapjoin9.srcbucket_mapjoin_part_1'
-''
-'  Stage: Stage-2'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        file:!!{hive.exec.scratchdir}!! '
-'          Select Operator'
-'            Select Operator'
-'              Group By Operator'
-'                aggregations:'
-'                      expr: count()'
-'                bucketGroup: false'
-'                mode: hash'
-'                outputColumnNames: _col0'
-'                Reduce Output Operator'
-'                  sort order: '
-'                  tag: -1'
-'                  value expressions:'
-'                        expr: _col0'
-'                        type: bigint'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        file:!!{hive.exec.scratchdir}!! [file:!!{hive.exec.scratchdir}!!]'
-'      Path -> Partition:'
-'        file:!!{hive.exec.scratchdir}!! '
-'          Partition'
-'            base file name: -mr-10002'
-'            input format: org.apache.hadoop.mapred.SequenceFileInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat'
-'            properties:'
-'              columns '
-'              columns.types '
-'              escape.delim \'
-'          '
-'              input format: org.apache.hadoop.mapred.SequenceFileInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat'
-'              properties:'
-'                columns '
-'                columns.types '
-'                escape.delim \'
-'      Reduce Operator Tree:'
-'        Group By Operator'
-'          aggregations:'
-'                expr: count(VALUE._col0)'
-'          bucketGroup: false'
-'          mode: mergepartial'
-'          outputColumnNames: _col0'
-'          Select Operator'
-'            expressions:'
-'                  expr: _col0'
-'                  type: bigint'
-'            outputColumnNames: _col0'
-'            File Output Operator'
-'              compressed: false'
-'              GlobalTableId: 0'
-'              directory: file:!!{hive.exec.scratchdir}!!'
-'              NumFilesPerFileSink: 1'
-'              Stats Publishing Key Prefix: file:!!{hive.exec.scratchdir}!!'
-'              table:'
-'                  input format: org.apache.hadoop.mapred.TextInputFormat'
-'                  output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                  properties:'
-'                    columns _col0'
-'                    columns.types bigint'
-'                    escape.delim \'
-'                    serialization.format 1'
-'              TotalFiles: 1'
-'              GatherStats: false'
-'              MultiFileSpray: false'
-''
-'  Stage: Stage-0'
-'    Fetch Operator'
-'      limit: -1'
-''
-''
-196 rows selected 
->>>  
->>>  SELECT /*+ MAPJOIN(b) */ count(*) 
-FROM srcbucket_mapjoin_part_1 a JOIN srcbucket_mapjoin_part_2 b 
-ON a.key = b.key AND a.part = '1' and b.part = '1';
-'_c1'
-'464'
-1 row selected 
->>>  
->>>  ALTER TABLE srcbucket_mapjoin_part_2 DROP PARTITION (part='1');
-No rows affected 
->>>  ALTER TABLE srcbucket_mapjoin_part_2 CLUSTERED BY (value) INTO 2 BUCKETS;
-No rows affected 
->>>  LOAD DATA LOCAL INPATH '../data/files/srcbucket20.txt' INTO TABLE srcbucket_mapjoin_part_2 PARTITION (part='1');
-No rows affected 
->>>  LOAD DATA LOCAL INPATH '../data/files/srcbucket21.txt' INTO TABLE srcbucket_mapjoin_part_2 PARTITION (part='1');
-No rows affected 
->>>  
->>>  ALTER TABLE srcbucket_mapjoin_part_2 CLUSTERED BY (key) INTO 2 BUCKETS;
-No rows affected 
->>>  
->>>  -- The table bucketing metadata matches but the partitions are bucketed on different columns, bucket map join should not be used
->>>  
->>>  EXPLAIN EXTENDED 
-SELECT /*+ MAPJOIN(b) */ count(*) 
-FROM srcbucket_mapjoin_part_1 a JOIN srcbucket_mapjoin_part_2 b 
-ON a.key = b.key AND a.part = '1' AND b.part = '1';
-'Explain'
-'ABSTRACT SYNTAX TREE:'
-'  (TOK_QUERY (TOK_FROM (TOK_JOIN (TOK_TABREF (TOK_TABNAME srcbucket_mapjoin_part_1) a) (TOK_TABREF (TOK_TABNAME srcbucket_mapjoin_part_2) b) (AND (AND (= (. (TOK_TABLE_OR_COL a) key) (. (TOK_TABLE_OR_COL b) key)) (= (. (TOK_TABLE_OR_COL a) part) '1')) (= (. (TOK_TABLE_OR_COL b) part) '1')))) (TOK_INSERT (TOK_DESTINATION (TOK_DIR TOK_TMP_FILE)) (TOK_SELECT (TOK_HINTLIST (TOK_HINT TOK_MAPJOIN (TOK_HINTARGLIST b))) (TOK_SELEXPR (TOK_FUNCTIONSTAR count)))))'
-''
-'STAGE DEPENDENCIES:'
-'  Stage-4 is a root stage'
-'  Stage-1 depends on stages: Stage-4'
-'  Stage-2 depends on stages: Stage-1'
-'  Stage-0 is a root stage'
-''
-'STAGE PLANS:'
-'  Stage: Stage-4'
-'    Map Reduce Local Work'
-'      Alias -> Map Local Tables:'
-'        b '
-'          Fetch Operator'
-'            limit: -1'
-'      Alias -> Map Local Operator Tree:'
-'        b '
-'          TableScan'
-'            alias: b'
-'            GatherStats: false'
-'            HashTable Sink Operator'
-'              condition expressions:'
-'                0 '
-'                1 '
-'              handleSkewJoin: false'
-'              keys:'
-'                0 [Column[key]]'
-'                1 [Column[key]]'
-'              Position of Big Table: 0'
-''
-'  Stage: Stage-1'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        a '
-'          TableScan'
-'            alias: a'
-'            GatherStats: false'
-'            Map Join Operator'
-'              condition map:'
-'                   Inner Join 0 to 1'
-'              condition expressions:'
-'                0 '
-'                1 '
-'              handleSkewJoin: false'
-'              keys:'
-'                0 [Column[key]]'
-'                1 [Column[key]]'
-'              Position of Big Table: 0'
-'              File Output Operator'
-'                compressed: false'
-'                GlobalTableId: 0'
-'                directory: file:!!{hive.exec.scratchdir}!!'
-'                NumFilesPerFileSink: 1'
-'                table:'
-'                    input format: org.apache.hadoop.mapred.SequenceFileInputFormat'
-'                    output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat'
-'                    properties:'
-'                      columns '
-'                      columns.types '
-'                      escape.delim \'
-'                TotalFiles: 1'
-'                GatherStats: false'
-'                MultiFileSpray: false'
-'      Local Work:'
-'        Map Reduce Local Work'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        !!{hive.metastore.warehouse.dir}!!/bucketmapjoin9.db/srcbucket_mapjoin_part_1/part=1 [a]'
-'      Path -> Partition:'
-'        !!{hive.metastore.warehouse.dir}!!/bucketmapjoin9.db/srcbucket_mapjoin_part_1/part=1 '
-'          Partition'
-'            base file name: part=1'
-'            input format: org.apache.hadoop.mapred.TextInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'            partition values:'
-'              part 1'
-'            properties:'
-'              bucket_count 2'
-'              bucket_field_name key'
-'              columns key,value'
-'              columns.types int:string'
-'              file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'              file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin9.db/srcbucket_mapjoin_part_1/part=1'
-'              name bucketmapjoin9.srcbucket_mapjoin_part_1'
-'              numFiles 2'
-'              numPartitions 1'
-'              numRows 0'
-'              partition_columns part'
-'              rawDataSize 0'
-'              serialization.ddl struct srcbucket_mapjoin_part_1 { i32 key, string value}'
-'              serialization.format 1'
-'              serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              totalSize 2750'
-'              transient_lastDdlTime !!UNIXTIME!!'
-'            serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'          '
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count 2'
-'                bucket_field_name key'
-'                columns key,value'
-'                columns.types int:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin9.db/srcbucket_mapjoin_part_1'
-'                name bucketmapjoin9.srcbucket_mapjoin_part_1'
-'                numFiles 2'
-'                numPartitions 1'
-'                numRows 0'
-'                partition_columns part'
-'                rawDataSize 0'
-'                serialization.ddl struct srcbucket_mapjoin_part_1 { i32 key, string value}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                totalSize 2750'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin9.srcbucket_mapjoin_part_1'
-'            name: bucketmapjoin9.srcbucket_mapjoin_part_1'
-''
-'  Stage: Stage-2'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        file:!!{hive.exec.scratchdir}!! '
-'          Select Operator'
-'            Select Operator'
-'              Group By Operator'
-'                aggregations:'
-'                      expr: count()'
-'                bucketGroup: false'
-'                mode: hash'
-'                outputColumnNames: _col0'
-'                Reduce Output Operator'
-'                  sort order: '
-'                  tag: -1'
-'                  value expressions:'
-'                        expr: _col0'
-'                        type: bigint'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        file:!!{hive.exec.scratchdir}!! [file:!!{hive.exec.scratchdir}!!]'
-'      Path -> Partition:'
-'        file:!!{hive.exec.scratchdir}!! '
-'          Partition'
-'            base file name: -mr-10002'
-'            input format: org.apache.hadoop.mapred.SequenceFileInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat'
-'            properties:'
-'              columns '
-'              columns.types '
-'              escape.delim \'
-'          '
-'              input format: org.apache.hadoop.mapred.SequenceFileInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat'
-'              properties:'
-'                columns '
-'                columns.types '
-'                escape.delim \'
-'      Reduce Operator Tree:'
-'        Group By Operator'
-'          aggregations:'
-'                expr: count(VALUE._col0)'
-'          bucketGroup: false'
-'          mode: mergepartial'
-'          outputColumnNames: _col0'
-'          Select Operator'
-'            expressions:'
-'                  expr: _col0'
-'                  type: bigint'
-'            outputColumnNames: _col0'
-'            File Output Operator'
-'              compressed: false'
-'              GlobalTableId: 0'
-'              directory: file:!!{hive.exec.scratchdir}!!'
-'              NumFilesPerFileSink: 1'
-'              Stats Publishing Key Prefix: file:!!{hive.exec.scratchdir}!!'
-'              table:'
-'                  input format: org.apache.hadoop.mapred.TextInputFormat'
-'                  output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                  properties:'
-'                    columns _col0'
-'                    columns.types bigint'
-'                    escape.delim \'
-'                    serialization.format 1'
-'              TotalFiles: 1'
-'              GatherStats: false'
-'              MultiFileSpray: false'
-''
-'  Stage: Stage-0'
-'    Fetch Operator'
-'      limit: -1'
-''
-''
-196 rows selected 
->>>  
->>>  SELECT /*+ MAPJOIN(b) */ count(*) 
-FROM srcbucket_mapjoin_part_1 a JOIN srcbucket_mapjoin_part_2 b 
-ON a.key = b.key AND a.part = '1' AND b.part = '1';
-'_c1'
-'464'
-1 row selected 
->>>  !record

http://git-wip-us.apache.org/repos/asf/hive/blob/3890ed65/ql/src/test/results/beelinepositive/bucketmapjoin_negative.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/beelinepositive/bucketmapjoin_negative.q.out b/ql/src/test/results/beelinepositive/bucketmapjoin_negative.q.out
deleted file mode 100644
index 60c6b63..0000000
--- a/ql/src/test/results/beelinepositive/bucketmapjoin_negative.q.out
+++ /dev/null
@@ -1,383 +0,0 @@
-Saving all output to "!!{outputDirectory}!!/bucketmapjoin_negative.q.raw". Enter "record" with no arguments to stop it.
->>>  !run !!{qFileDirectory}!!/bucketmapjoin_negative.q
->>>  
->>>  
->>>  
->>>  
->>>  CREATE TABLE srcbucket_mapjoin(key int, value string) CLUSTERED BY (key) INTO 2 BUCKETS STORED AS TEXTFILE;
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket20.txt' INTO TABLE srcbucket_mapjoin;
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket21.txt' INTO TABLE srcbucket_mapjoin;
-No rows affected 
->>>  
->>>  CREATE TABLE srcbucket_mapjoin_part (key int, value string) partitioned by (ds string) CLUSTERED BY (key) INTO 3 BUCKETS STORED AS TEXTFILE;
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket20.txt' INTO TABLE srcbucket_mapjoin_part partition(ds='2008-04-08');
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket21.txt' INTO TABLE srcbucket_mapjoin_part partition(ds='2008-04-08');
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket22.txt' INTO TABLE srcbucket_mapjoin_part partition(ds='2008-04-08');
-No rows affected 
->>>  
->>>  
->>>  
->>>  set hive.optimize.bucketmapjoin = true;
-No rows affected 
->>>  create table bucketmapjoin_tmp_result (key string , value1 string, value2 string);
-No rows affected 
->>>  
->>>  explain extended 
-insert overwrite table bucketmapjoin_tmp_result 
-select /*+mapjoin(b)*/ a.key, a.value, b.value 
-from srcbucket_mapjoin a join srcbucket_mapjoin_part b 
-on a.key=b.key where b.ds="2008-04-08";
-'Explain'
-'ABSTRACT SYNTAX TREE:'
-'  (TOK_QUERY (TOK_FROM (TOK_JOIN (TOK_TABREF (TOK_TABNAME srcbucket_mapjoin) a) (TOK_TABREF (TOK_TABNAME srcbucket_mapjoin_part) b) (= (. (TOK_TABLE_OR_COL a) key) (. (TOK_TABLE_OR_COL b) key)))) (TOK_INSERT (TOK_DESTINATION (TOK_TAB (TOK_TABNAME bucketmapjoin_tmp_result))) (TOK_SELECT (TOK_HINTLIST (TOK_HINT TOK_MAPJOIN (TOK_HINTARGLIST b))) (TOK_SELEXPR (. (TOK_TABLE_OR_COL a) key)) (TOK_SELEXPR (. (TOK_TABLE_OR_COL a) value)) (TOK_SELEXPR (. (TOK_TABLE_OR_COL b) value))) (TOK_WHERE (= (. (TOK_TABLE_OR_COL b) ds) "2008-04-08"))))'
-''
-'STAGE DEPENDENCIES:'
-'  Stage-9 is a root stage'
-'  Stage-1 depends on stages: Stage-9'
-'  Stage-7 depends on stages: Stage-1 , consists of Stage-4, Stage-3, Stage-5'
-'  Stage-4'
-'  Stage-0 depends on stages: Stage-4, Stage-3, Stage-6'
-'  Stage-2 depends on stages: Stage-0'
-'  Stage-3'
-'  Stage-5'
-'  Stage-6 depends on stages: Stage-5'
-''
-'STAGE PLANS:'
-'  Stage: Stage-9'
-'    Map Reduce Local Work'
-'      Alias -> Map Local Tables:'
-'        b '
-'          Fetch Operator'
-'            limit: -1'
-'      Alias -> Map Local Operator Tree:'
-'        b '
-'          TableScan'
-'            alias: b'
-'            GatherStats: false'
-'            HashTable Sink Operator'
-'              condition expressions:'
-'                0 {key} {value}'
-'                1 {value} {ds}'
-'              handleSkewJoin: false'
-'              keys:'
-'                0 [Column[key]]'
-'                1 [Column[key]]'
-'              Position of Big Table: 0'
-''
-'  Stage: Stage-1'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        a '
-'          TableScan'
-'            alias: a'
-'            GatherStats: false'
-'            Map Join Operator'
-'              condition map:'
-'                   Inner Join 0 to 1'
-'              condition expressions:'
-'                0 {key} {value}'
-'                1 {value} {ds}'
-'              handleSkewJoin: false'
-'              keys:'
-'                0 [Column[key]]'
-'                1 [Column[key]]'
-'              outputColumnNames: _col0, _col1, _col5, _col6'
-'              Position of Big Table: 0'
-'              Select Operator'
-'                expressions:'
-'                      expr: _col0'
-'                      type: int'
-'                      expr: _col1'
-'                      type: string'
-'                      expr: _col5'
-'                      type: string'
-'                      expr: _col6'
-'                      type: string'
-'                outputColumnNames: _col0, _col1, _col5, _col6'
-'                Select Operator'
-'                  expressions:'
-'                        expr: _col0'
-'                        type: int'
-'                        expr: _col1'
-'                        type: string'
-'                        expr: _col5'
-'                        type: string'
-'                  outputColumnNames: _col0, _col1, _col2'
-'                  File Output Operator'
-'                    compressed: false'
-'                    GlobalTableId: 1'
-'                    directory: pfile:!!{hive.exec.scratchdir}!!'
-'                    NumFilesPerFileSink: 1'
-'                    Stats Publishing Key Prefix: pfile:!!{hive.exec.scratchdir}!!'
-'                    table:'
-'                        input format: org.apache.hadoop.mapred.TextInputFormat'
-'                        output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                        properties:'
-'                          bucket_count -1'
-'                          columns key,value1,value2'
-'                          columns.types string:string:string'
-'                          file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                          file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                          location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/bucketmapjoin_tmp_result'
-'                          name bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'                          serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                          serialization.format 1'
-'                          serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                          transient_lastDdlTime !!UNIXTIME!!'
-'                        serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                        name: bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'                    TotalFiles: 1'
-'                    GatherStats: true'
-'                    MultiFileSpray: false'
-'      Local Work:'
-'        Map Reduce Local Work'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/srcbucket_mapjoin [a]'
-'      Path -> Partition:'
-'        !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/srcbucket_mapjoin '
-'          Partition'
-'            base file name: srcbucket_mapjoin'
-'            input format: org.apache.hadoop.mapred.TextInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'            properties:'
-'              bucket_count 2'
-'              bucket_field_name key'
-'              columns key,value'
-'              columns.types int:string'
-'              file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'              file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/srcbucket_mapjoin'
-'              name bucketmapjoin_negative.srcbucket_mapjoin'
-'              numFiles 2'
-'              numPartitions 0'
-'              numRows 0'
-'              rawDataSize 0'
-'              serialization.ddl struct srcbucket_mapjoin { i32 key, string value}'
-'              serialization.format 1'
-'              serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              totalSize 2750'
-'              transient_lastDdlTime !!UNIXTIME!!'
-'            serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'          '
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count 2'
-'                bucket_field_name key'
-'                columns key,value'
-'                columns.types int:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/srcbucket_mapjoin'
-'                name bucketmapjoin_negative.srcbucket_mapjoin'
-'                numFiles 2'
-'                numPartitions 0'
-'                numRows 0'
-'                rawDataSize 0'
-'                serialization.ddl struct srcbucket_mapjoin { i32 key, string value}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                totalSize 2750'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin_negative.srcbucket_mapjoin'
-'            name: bucketmapjoin_negative.srcbucket_mapjoin'
-''
-'  Stage: Stage-7'
-'    Conditional Operator'
-''
-'  Stage: Stage-4'
-'    Move Operator'
-'      files:'
-'          hdfs directory: true'
-'          source: pfile:!!{hive.exec.scratchdir}!!'
-'          destination: pfile:!!{hive.exec.scratchdir}!!'
-''
-'  Stage: Stage-0'
-'    Move Operator'
-'      tables:'
-'          replace: true'
-'          source: pfile:!!{hive.exec.scratchdir}!!'
-'          table:'
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count -1'
-'                columns key,value1,value2'
-'                columns.types string:string:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/bucketmapjoin_tmp_result'
-'                name bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'                serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'          tmp directory: pfile:!!{hive.exec.scratchdir}!!'
-''
-'  Stage: Stage-2'
-'    Stats-Aggr Operator'
-'      Stats Aggregation Key Prefix: pfile:!!{hive.exec.scratchdir}!!'
-''
-'  Stage: Stage-3'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        pfile:!!{hive.exec.scratchdir}!! '
-'            File Output Operator'
-'              compressed: false'
-'              GlobalTableId: 0'
-'              directory: pfile:!!{hive.exec.scratchdir}!!'
-'              NumFilesPerFileSink: 1'
-'              table:'
-'                  input format: org.apache.hadoop.mapred.TextInputFormat'
-'                  output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                  properties:'
-'                    bucket_count -1'
-'                    columns key,value1,value2'
-'                    columns.types string:string:string'
-'                    file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                    file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                    location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/bucketmapjoin_tmp_result'
-'                    name bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'                    serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                    serialization.format 1'
-'                    serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                    transient_lastDdlTime !!UNIXTIME!!'
-'                  serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                  name: bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'              TotalFiles: 1'
-'              GatherStats: false'
-'              MultiFileSpray: false'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        pfile:!!{hive.exec.scratchdir}!! [pfile:!!{hive.exec.scratchdir}!!]'
-'      Path -> Partition:'
-'        pfile:!!{hive.exec.scratchdir}!! '
-'          Partition'
-'            base file name: -ext-10002'
-'            input format: org.apache.hadoop.mapred.TextInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'            properties:'
-'              bucket_count -1'
-'              columns key,value1,value2'
-'              columns.types string:string:string'
-'              file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'              file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/bucketmapjoin_tmp_result'
-'              name bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'              serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'              serialization.format 1'
-'              serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              transient_lastDdlTime !!UNIXTIME!!'
-'            serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'          '
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count -1'
-'                columns key,value1,value2'
-'                columns.types string:string:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/bucketmapjoin_tmp_result'
-'                name bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'                serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'            name: bucketmapjoin_negative.bucketmapjoin_tmp_result'
-''
-'  Stage: Stage-5'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        pfile:!!{hive.exec.scratchdir}!! '
-'            File Output Operator'
-'              compressed: false'
-'              GlobalTableId: 0'
-'              directory: pfile:!!{hive.exec.scratchdir}!!'
-'              NumFilesPerFileSink: 1'
-'              table:'
-'                  input format: org.apache.hadoop.mapred.TextInputFormat'
-'                  output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                  properties:'
-'                    bucket_count -1'
-'                    columns key,value1,value2'
-'                    columns.types string:string:string'
-'                    file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                    file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                    location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/bucketmapjoin_tmp_result'
-'                    name bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'                    serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                    serialization.format 1'
-'                    serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                    transient_lastDdlTime !!UNIXTIME!!'
-'                  serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                  name: bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'              TotalFiles: 1'
-'              GatherStats: false'
-'              MultiFileSpray: false'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        pfile:!!{hive.exec.scratchdir}!! [pfile:!!{hive.exec.scratchdir}!!]'
-'      Path -> Partition:'
-'        pfile:!!{hive.exec.scratchdir}!! '
-'          Partition'
-'            base file name: -ext-10002'
-'            input format: org.apache.hadoop.mapred.TextInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'            properties:'
-'              bucket_count -1'
-'              columns key,value1,value2'
-'              columns.types string:string:string'
-'              file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'              file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/bucketmapjoin_tmp_result'
-'              name bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'              serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'              serialization.format 1'
-'              serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              transient_lastDdlTime !!UNIXTIME!!'
-'            serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'          '
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count -1'
-'                columns key,value1,value2'
-'                columns.types string:string:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative.db/bucketmapjoin_tmp_result'
-'                name bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'                serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin_negative.bucketmapjoin_tmp_result'
-'            name: bucketmapjoin_negative.bucketmapjoin_tmp_result'
-''
-'  Stage: Stage-6'
-'    Move Operator'
-'      files:'
-'          hdfs directory: true'
-'          source: pfile:!!{hive.exec.scratchdir}!!'
-'          destination: pfile:!!{hive.exec.scratchdir}!!'
-''
-''
-342 rows selected 
->>>  
->>>  
->>>  
->>>  
->>>  !record

http://git-wip-us.apache.org/repos/asf/hive/blob/3890ed65/ql/src/test/results/beelinepositive/bucketmapjoin_negative2.q.out
----------------------------------------------------------------------
diff --git a/ql/src/test/results/beelinepositive/bucketmapjoin_negative2.q.out b/ql/src/test/results/beelinepositive/bucketmapjoin_negative2.q.out
deleted file mode 100644
index fc6e76e..0000000
--- a/ql/src/test/results/beelinepositive/bucketmapjoin_negative2.q.out
+++ /dev/null
@@ -1,381 +0,0 @@
-Saving all output to "!!{outputDirectory}!!/bucketmapjoin_negative2.q.raw". Enter "record" with no arguments to stop it.
->>>  !run !!{qFileDirectory}!!/bucketmapjoin_negative2.q
->>>  CREATE TABLE srcbucket_mapjoin(key int, value string) CLUSTERED BY (key) INTO 2 BUCKETS STORED AS TEXTFILE;
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket20.txt' INTO TABLE srcbucket_mapjoin;
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket21.txt' INTO TABLE srcbucket_mapjoin;
-No rows affected 
->>>  
->>>  CREATE TABLE srcbucket_mapjoin_part_2 (key int, value string) partitioned by (ds string) CLUSTERED BY (key) INTO 2 BUCKETS STORED AS TEXTFILE;
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket22.txt' INTO TABLE srcbucket_mapjoin_part_2 partition(ds='2008-04-08');
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket23.txt' INTO TABLE srcbucket_mapjoin_part_2 partition(ds='2008-04-08');
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket22.txt' INTO TABLE srcbucket_mapjoin_part_2 partition(ds='2008-04-09');
-No rows affected 
->>>  load data local inpath '../data/files/srcbucket23.txt' INTO TABLE srcbucket_mapjoin_part_2 partition(ds='2008-04-09');
-No rows affected 
->>>  
->>>  set hive.optimize.bucketmapjoin = true;
-No rows affected 
->>>  create table bucketmapjoin_tmp_result (key string , value1 string, value2 string);
-No rows affected 
->>>  
->>>  explain extended 
-insert overwrite table bucketmapjoin_tmp_result 
-select /*+mapjoin(b)*/ a.key, a.value, b.value 
-from srcbucket_mapjoin a join srcbucket_mapjoin_part_2 b 
-on a.key=b.key;
-'Explain'
-'ABSTRACT SYNTAX TREE:'
-'  (TOK_QUERY (TOK_FROM (TOK_JOIN (TOK_TABREF (TOK_TABNAME srcbucket_mapjoin) a) (TOK_TABREF (TOK_TABNAME srcbucket_mapjoin_part_2) b) (= (. (TOK_TABLE_OR_COL a) key) (. (TOK_TABLE_OR_COL b) key)))) (TOK_INSERT (TOK_DESTINATION (TOK_TAB (TOK_TABNAME bucketmapjoin_tmp_result))) (TOK_SELECT (TOK_HINTLIST (TOK_HINT TOK_MAPJOIN (TOK_HINTARGLIST b))) (TOK_SELEXPR (. (TOK_TABLE_OR_COL a) key)) (TOK_SELEXPR (. (TOK_TABLE_OR_COL a) value)) (TOK_SELEXPR (. (TOK_TABLE_OR_COL b) value)))))'
-''
-'STAGE DEPENDENCIES:'
-'  Stage-9 is a root stage'
-'  Stage-1 depends on stages: Stage-9'
-'  Stage-7 depends on stages: Stage-1 , consists of Stage-4, Stage-3, Stage-5'
-'  Stage-4'
-'  Stage-0 depends on stages: Stage-4, Stage-3, Stage-6'
-'  Stage-2 depends on stages: Stage-0'
-'  Stage-3'
-'  Stage-5'
-'  Stage-6 depends on stages: Stage-5'
-''
-'STAGE PLANS:'
-'  Stage: Stage-9'
-'    Map Reduce Local Work'
-'      Alias -> Map Local Tables:'
-'        b '
-'          Fetch Operator'
-'            limit: -1'
-'      Alias -> Map Local Operator Tree:'
-'        b '
-'          TableScan'
-'            alias: b'
-'            GatherStats: false'
-'            HashTable Sink Operator'
-'              condition expressions:'
-'                0 {key} {value}'
-'                1 {value}'
-'              handleSkewJoin: false'
-'              keys:'
-'                0 [Column[key]]'
-'                1 [Column[key]]'
-'              Position of Big Table: 0'
-'      Bucket Mapjoin Context:'
-'          Alias Bucket Base File Name Mapping:'
-'            b {srcbucket20.txt=[ds=2008-04-08/srcbucket22.txt, ds=2008-04-09/srcbucket22.txt], srcbucket21.txt=[ds=2008-04-08/srcbucket23.txt, ds=2008-04-09/srcbucket23.txt]}'
-'          Alias Bucket File Name Mapping:'
-'            b {!!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin/srcbucket20.txt=[!!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin_part_2/ds=2008-04-08/srcbucket22.txt, !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin_part_2/ds=2008-04-09/srcbucket22.txt], !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin/srcbucket21.txt=[!!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin_part_2/ds=2008-04-08/srcbucket23.txt, !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin_part_2/ds=2008-04-09/srcbucket23.txt]}'
-'          Alias Bucket Output File Name Mapping:'
-'            !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin/srcbucket20.txt 0'
-'            !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin/srcbucket21.txt 1'
-''
-'  Stage: Stage-1'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        a '
-'          TableScan'
-'            alias: a'
-'            GatherStats: false'
-'            Map Join Operator'
-'              condition map:'
-'                   Inner Join 0 to 1'
-'              condition expressions:'
-'                0 {key} {value}'
-'                1 {value}'
-'              handleSkewJoin: false'
-'              keys:'
-'                0 [Column[key]]'
-'                1 [Column[key]]'
-'              outputColumnNames: _col0, _col1, _col5'
-'              Position of Big Table: 0'
-'              Select Operator'
-'                expressions:'
-'                      expr: _col0'
-'                      type: int'
-'                      expr: _col1'
-'                      type: string'
-'                      expr: _col5'
-'                      type: string'
-'                outputColumnNames: _col0, _col1, _col5'
-'                Select Operator'
-'                  expressions:'
-'                        expr: _col0'
-'                        type: int'
-'                        expr: _col1'
-'                        type: string'
-'                        expr: _col5'
-'                        type: string'
-'                  outputColumnNames: _col0, _col1, _col2'
-'                  File Output Operator'
-'                    compressed: false'
-'                    GlobalTableId: 1'
-'                    directory: pfile:!!{hive.exec.scratchdir}!!'
-'                    NumFilesPerFileSink: 1'
-'                    Stats Publishing Key Prefix: pfile:!!{hive.exec.scratchdir}!!'
-'                    table:'
-'                        input format: org.apache.hadoop.mapred.TextInputFormat'
-'                        output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                        properties:'
-'                          bucket_count -1'
-'                          columns key,value1,value2'
-'                          columns.types string:string:string'
-'                          file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                          file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                          location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/bucketmapjoin_tmp_result'
-'                          name bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'                          serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                          serialization.format 1'
-'                          serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                          transient_lastDdlTime !!UNIXTIME!!'
-'                        serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                        name: bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'                    TotalFiles: 1'
-'                    GatherStats: true'
-'                    MultiFileSpray: false'
-'      Local Work:'
-'        Map Reduce Local Work'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin [a]'
-'      Path -> Partition:'
-'        !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin '
-'          Partition'
-'            base file name: srcbucket_mapjoin'
-'            input format: org.apache.hadoop.mapred.TextInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'            properties:'
-'              bucket_count 2'
-'              bucket_field_name key'
-'              columns key,value'
-'              columns.types int:string'
-'              file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'              file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin'
-'              name bucketmapjoin_negative2.srcbucket_mapjoin'
-'              numFiles 2'
-'              numPartitions 0'
-'              numRows 0'
-'              rawDataSize 0'
-'              serialization.ddl struct srcbucket_mapjoin { i32 key, string value}'
-'              serialization.format 1'
-'              serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              totalSize 2750'
-'              transient_lastDdlTime !!UNIXTIME!!'
-'            serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'          '
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count 2'
-'                bucket_field_name key'
-'                columns key,value'
-'                columns.types int:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/srcbucket_mapjoin'
-'                name bucketmapjoin_negative2.srcbucket_mapjoin'
-'                numFiles 2'
-'                numPartitions 0'
-'                numRows 0'
-'                rawDataSize 0'
-'                serialization.ddl struct srcbucket_mapjoin { i32 key, string value}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                totalSize 2750'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin_negative2.srcbucket_mapjoin'
-'            name: bucketmapjoin_negative2.srcbucket_mapjoin'
-''
-'  Stage: Stage-7'
-'    Conditional Operator'
-''
-'  Stage: Stage-4'
-'    Move Operator'
-'      files:'
-'          hdfs directory: true'
-'          source: pfile:!!{hive.exec.scratchdir}!!'
-'          destination: pfile:!!{hive.exec.scratchdir}!!'
-''
-'  Stage: Stage-0'
-'    Move Operator'
-'      tables:'
-'          replace: true'
-'          source: pfile:!!{hive.exec.scratchdir}!!'
-'          table:'
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count -1'
-'                columns key,value1,value2'
-'                columns.types string:string:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/bucketmapjoin_tmp_result'
-'                name bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'                serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'          tmp directory: pfile:!!{hive.exec.scratchdir}!!'
-''
-'  Stage: Stage-2'
-'    Stats-Aggr Operator'
-'      Stats Aggregation Key Prefix: pfile:!!{hive.exec.scratchdir}!!'
-''
-'  Stage: Stage-3'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        pfile:!!{hive.exec.scratchdir}!! '
-'            File Output Operator'
-'              compressed: false'
-'              GlobalTableId: 0'
-'              directory: pfile:!!{hive.exec.scratchdir}!!'
-'              NumFilesPerFileSink: 1'
-'              table:'
-'                  input format: org.apache.hadoop.mapred.TextInputFormat'
-'                  output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                  properties:'
-'                    bucket_count -1'
-'                    columns key,value1,value2'
-'                    columns.types string:string:string'
-'                    file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                    file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                    location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/bucketmapjoin_tmp_result'
-'                    name bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'                    serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                    serialization.format 1'
-'                    serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                    transient_lastDdlTime !!UNIXTIME!!'
-'                  serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                  name: bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'              TotalFiles: 1'
-'              GatherStats: false'
-'              MultiFileSpray: false'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        pfile:!!{hive.exec.scratchdir}!! [pfile:!!{hive.exec.scratchdir}!!]'
-'      Path -> Partition:'
-'        pfile:!!{hive.exec.scratchdir}!! '
-'          Partition'
-'            base file name: -ext-10002'
-'            input format: org.apache.hadoop.mapred.TextInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'            properties:'
-'              bucket_count -1'
-'              columns key,value1,value2'
-'              columns.types string:string:string'
-'              file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'              file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/bucketmapjoin_tmp_result'
-'              name bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'              serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'              serialization.format 1'
-'              serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              transient_lastDdlTime !!UNIXTIME!!'
-'            serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'          '
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count -1'
-'                columns key,value1,value2'
-'                columns.types string:string:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/bucketmapjoin_tmp_result'
-'                name bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'                serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'            name: bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-''
-'  Stage: Stage-5'
-'    Map Reduce'
-'      Alias -> Map Operator Tree:'
-'        pfile:!!{hive.exec.scratchdir}!! '
-'            File Output Operator'
-'              compressed: false'
-'              GlobalTableId: 0'
-'              directory: pfile:!!{hive.exec.scratchdir}!!'
-'              NumFilesPerFileSink: 1'
-'              table:'
-'                  input format: org.apache.hadoop.mapred.TextInputFormat'
-'                  output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                  properties:'
-'                    bucket_count -1'
-'                    columns key,value1,value2'
-'                    columns.types string:string:string'
-'                    file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                    file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                    location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/bucketmapjoin_tmp_result'
-'                    name bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'                    serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                    serialization.format 1'
-'                    serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                    transient_lastDdlTime !!UNIXTIME!!'
-'                  serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                  name: bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'              TotalFiles: 1'
-'              GatherStats: false'
-'              MultiFileSpray: false'
-'      Needs Tagging: false'
-'      Path -> Alias:'
-'        pfile:!!{hive.exec.scratchdir}!! [pfile:!!{hive.exec.scratchdir}!!]'
-'      Path -> Partition:'
-'        pfile:!!{hive.exec.scratchdir}!! '
-'          Partition'
-'            base file name: -ext-10002'
-'            input format: org.apache.hadoop.mapred.TextInputFormat'
-'            output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'            properties:'
-'              bucket_count -1'
-'              columns key,value1,value2'
-'              columns.types string:string:string'
-'              file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'              file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/bucketmapjoin_tmp_result'
-'              name bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'              serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'              serialization.format 1'
-'              serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              transient_lastDdlTime !!UNIXTIME!!'
-'            serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'          '
-'              input format: org.apache.hadoop.mapred.TextInputFormat'
-'              output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'              properties:'
-'                bucket_count -1'
-'                columns key,value1,value2'
-'                columns.types string:string:string'
-'                file.inputformat org.apache.hadoop.mapred.TextInputFormat'
-'                file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
-'                location !!{hive.metastore.warehouse.dir}!!/bucketmapjoin_negative2.db/bucketmapjoin_tmp_result'
-'                name bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'                serialization.ddl struct bucketmapjoin_tmp_result { string key, string value1, string value2}'
-'                serialization.format 1'
-'                serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'                transient_lastDdlTime !!UNIXTIME!!'
-'              serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'
-'              name: bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-'            name: bucketmapjoin_negative2.bucketmapjoin_tmp_result'
-''
-'  Stage: Stage-6'
-'    Move Operator'
-'      files:'
-'          hdfs directory: true'
-'          source: pfile:!!{hive.exec.scratchdir}!!'
-'          destination: pfile:!!{hive.exec.scratchdir}!!'
-''
-''
-348 rows selected 
->>>  !record


Mime
View raw message