You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by na...@apache.org on 2010/01/16 07:46:07 UTC
svn commit: r899891 [6/31] - in /hadoop/hive/trunk: ./
common/src/java/org/apache/hadoop/hive/conf/ conf/
ql/src/java/org/apache/hadoop/hive/ql/
ql/src/java/org/apache/hadoop/hive/ql/exec/
ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/ ql/src/...
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join33.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join33.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join33.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join33.q.out Sat Jan 16 06:44:01 2010
@@ -36,6 +36,7 @@
condition expressions:
0 {key} {value}
1 {value}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[key]]
@@ -44,7 +45,7 @@
File Output Operator
compressed: false
GlobalTableId: 0
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2025598674/10002
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1171659403/10002
table:
input format: org.apache.hadoop.mapred.SequenceFileInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
@@ -68,6 +69,7 @@
condition expressions:
0 {key} {value}
1 {value}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[key]]
@@ -76,7 +78,7 @@
File Output Operator
compressed: false
GlobalTableId: 0
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2025598674/10002
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1171659403/10002
table:
input format: org.apache.hadoop.mapred.SequenceFileInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
@@ -86,9 +88,9 @@
escape.delim \
Needs Tagging: false
Path -> Alias:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src [y]
+ file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/src [y]
Path -> Partition:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
+ file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/src
Partition
base file name: src
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -103,8 +105,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
- transient_lastDdlTime 1262136613
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/src
+ transient_lastDdlTime 1263595101
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -119,8 +121,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
- transient_lastDdlTime 1262136613
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/src
+ transient_lastDdlTime 1263595101
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: src
name: src
@@ -158,7 +160,7 @@
value expressions:
expr: value
type: string
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2025598674/10002
+ file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1171659403/10002
Select Operator
expressions:
expr: _col0
@@ -184,10 +186,10 @@
type: string
Needs Tagging: true
Path -> Alias:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/srcpart/ds=2008-04-08/hr=11 [z]
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2025598674/10002 [file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2025598674/10002]
+ file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/srcpart/ds=2008-04-08/hr=11 [z]
+ file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1171659403/10002 [file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1171659403/10002]
Path -> Partition:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/srcpart/ds=2008-04-08/hr=11
+ file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/srcpart/ds=2008-04-08/hr=11
Partition
base file name: hr=11
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -206,8 +208,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/srcpart
- transient_lastDdlTime 1262136612
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/srcpart
+ transient_lastDdlTime 1263595100
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -223,12 +225,12 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/srcpart
- transient_lastDdlTime 1262136612
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/srcpart
+ transient_lastDdlTime 1263595100
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: srcpart
name: srcpart
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2025598674/10002
+ file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1171659403/10002
Partition
base file name: 10002
input format: org.apache.hadoop.mapred.SequenceFileInputFormat
@@ -251,6 +253,7 @@
condition expressions:
0 {VALUE._col1} {VALUE._col2}
1 {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col1, _col2, _col5
Select Operator
expressions:
@@ -264,7 +267,7 @@
File Output Operator
compressed: false
GlobalTableId: 1
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/423853142/10000
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/919822712/10000
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -278,8 +281,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136614
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263595101
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
@@ -287,7 +290,7 @@
Move Operator
tables:
replace: true
- source: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/423853142/10000
+ source: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/919822712/10000
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -301,11 +304,11 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136614
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263595101
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
- tmp directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/423853142/10001
+ tmp directory: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/919822712/10001
PREHOOK: query: INSERT OVERWRITE TABLE dest_j1
@@ -329,11 +332,11 @@
PREHOOK: query: select * from dest_j1 x order by x.key
PREHOOK: type: QUERY
PREHOOK: Input: default@dest_j1
-PREHOOK: Output: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/590440109/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/707876168/10000
POSTHOOK: query: select * from dest_j1 x order by x.key
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest_j1
-POSTHOOK: Output: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/590440109/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/707876168/10000
146 val_146 val_146
146 val_146 val_146
146 val_146 val_146
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join34.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join34.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join34.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join34.q.out Sat Jan 16 06:44:01 2010
@@ -32,8 +32,10 @@
STAGE DEPENDENCIES:
Stage-1 is a root stage
- Stage-4 depends on stages: Stage-1
- Stage-0 depends on stages: Stage-4
+ Stage-4 depends on stages: Stage-1 , consists of Stage-3, Stage-2
+ Stage-3
+ Stage-0 depends on stages: Stage-3, Stage-2
+ Stage-2
STAGE PLANS:
Stage: Stage-1
@@ -66,6 +68,7 @@
condition expressions:
0 {_col1}
1 {key} {value}
+ handleSkewJoin: false
keys:
0 [Column[_col0]]
1 [Column[key]]
@@ -92,7 +95,7 @@
File Output Operator
compressed: false
GlobalTableId: 1
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/158952705/10002
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2117134462/10002
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -106,8 +109,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136625
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263594960
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
null-subquery2:subq1-subquery2:x1
@@ -137,6 +140,7 @@
condition expressions:
0 {_col1}
1 {key} {value}
+ handleSkewJoin: false
keys:
0 [Column[_col0]]
1 [Column[key]]
@@ -163,7 +167,7 @@
File Output Operator
compressed: false
GlobalTableId: 1
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/158952705/10002
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2117134462/10002
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -177,8 +181,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136625
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263594960
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
Local Work:
@@ -197,6 +201,7 @@
condition expressions:
0 {_col1}
1 {key} {value}
+ handleSkewJoin: false
keys:
0 [Column[_col0]]
1 [Column[key]]
@@ -223,7 +228,7 @@
File Output Operator
compressed: false
GlobalTableId: 1
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/158952705/10002
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2117134462/10002
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -237,15 +242,15 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136625
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263594960
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
Needs Tagging: false
Path -> Alias:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src [null-subquery1:subq1-subquery1:x, null-subquery2:subq1-subquery2:x1]
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/src [null-subquery1:subq1-subquery1:x, null-subquery2:subq1-subquery2:x1]
Path -> Partition:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/src
Partition
base file name: src
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -260,8 +265,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
- transient_lastDdlTime 1262136625
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/src
+ transient_lastDdlTime 1263594959
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -276,105 +281,27 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
- transient_lastDdlTime 1262136625
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/src
+ transient_lastDdlTime 1263594959
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: src
name: src
Stage: Stage-4
Conditional Operator
- list of dependent Tasks:
- Move Operator
- files:
- hdfs directory: true
- source: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/158952705/10002
- destination: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/1550747367/10000
- Map Reduce
- Alias -> Map Operator Tree:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/158952705/10002
- Reduce Output Operator
- sort order:
- Map-reduce partition columns:
- expr: rand()
- type: double
- tag: -1
- value expressions:
- expr: key
- type: string
- expr: value
- type: string
- expr: val2
- type: string
- Needs Tagging: false
- Path -> Alias:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/158952705/10002 [file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/158952705/10002]
- Path -> Partition:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/158952705/10002
- Partition
- base file name: 10002
- input format: org.apache.hadoop.mapred.TextInputFormat
- output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- properties:
- name dest_j1
- columns.types string:string:string
- serialization.ddl struct dest_j1 { string key, string value, string val2}
- serialization.format 1
- columns key,value,val2
- bucket_count -1
- serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- file.inputformat org.apache.hadoop.mapred.TextInputFormat
- file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136625
- 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:
- name dest_j1
- columns.types string:string:string
- serialization.ddl struct dest_j1 { string key, string value, string val2}
- serialization.format 1
- columns key,value,val2
- bucket_count -1
- serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- file.inputformat org.apache.hadoop.mapred.TextInputFormat
- file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136625
- serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- name: dest_j1
- name: dest_j1
- Reduce Operator Tree:
- Extract
- File Output Operator
- compressed: false
- GlobalTableId: 0
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/1550747367/10000
- table:
- input format: org.apache.hadoop.mapred.TextInputFormat
- output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- properties:
- name dest_j1
- columns.types string:string:string
- serialization.ddl struct dest_j1 { string key, string value, string val2}
- serialization.format 1
- columns key,value,val2
- bucket_count -1
- serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- file.inputformat org.apache.hadoop.mapred.TextInputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- transient_lastDdlTime 1262136625
- serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- name: dest_j1
+
+ Stage: Stage-3
+ Move Operator
+ files:
+ hdfs directory: true
+ source: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2117134462/10002
+ destination: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1735776239/10000
Stage: Stage-0
Move Operator
tables:
replace: true
- source: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/1550747367/10000
+ source: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1735776239/10000
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -388,11 +315,92 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136625
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263594960
+ serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ name: dest_j1
+ tmp directory: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1735776239/10001
+
+ Stage: Stage-2
+ Map Reduce
+ Alias -> Map Operator Tree:
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2117134462/10002
+ Reduce Output Operator
+ sort order:
+ Map-reduce partition columns:
+ expr: rand()
+ type: double
+ tag: -1
+ value expressions:
+ expr: key
+ type: string
+ expr: value
+ type: string
+ expr: val2
+ type: string
+ Needs Tagging: false
+ Path -> Alias:
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2117134462/10002 [file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2117134462/10002]
+ Path -> Partition:
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2117134462/10002
+ Partition
+ base file name: 10002
+ input format: org.apache.hadoop.mapred.TextInputFormat
+ output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ properties:
+ name dest_j1
+ columns.types string:string:string
+ serialization.ddl struct dest_j1 { string key, string value, string val2}
+ serialization.format 1
+ columns key,value,val2
+ bucket_count -1
+ serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ file.inputformat org.apache.hadoop.mapred.TextInputFormat
+ file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263594960
+ 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:
+ name dest_j1
+ columns.types string:string:string
+ serialization.ddl struct dest_j1 { string key, string value, string val2}
+ serialization.format 1
+ columns key,value,val2
+ bucket_count -1
+ serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ file.inputformat org.apache.hadoop.mapred.TextInputFormat
+ file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263594960
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
- tmp directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/1550747367/10001
+ name: dest_j1
+ Reduce Operator Tree:
+ Extract
+ File Output Operator
+ compressed: false
+ GlobalTableId: 0
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1735776239/10000
+ table:
+ input format: org.apache.hadoop.mapred.TextInputFormat
+ output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ properties:
+ name dest_j1
+ columns.types string:string:string
+ serialization.ddl struct dest_j1 { string key, string value, string val2}
+ serialization.format 1
+ columns key,value,val2
+ bucket_count -1
+ serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ file.inputformat org.apache.hadoop.mapred.TextInputFormat
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/test/data/warehouse/dest_j1
+ file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ transient_lastDdlTime 1263594960
+ serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ name: dest_j1
PREHOOK: query: INSERT OVERWRITE TABLE dest_j1
@@ -422,11 +430,11 @@
PREHOOK: query: select * from dest_j1 x order by x.key
PREHOOK: type: QUERY
PREHOOK: Input: default@dest_j1
-PREHOOK: Output: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/82522457/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2143694309/10000
POSTHOOK: query: select * from dest_j1 x order by x.key
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest_j1
-POSTHOOK: Output: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/82522457/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/2143694309/10000
128 val_128
128 val_128
128 val_128
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join35.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join35.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join35.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join35.q.out Sat Jan 16 06:44:01 2010
@@ -33,12 +33,11 @@
STAGE DEPENDENCIES:
Stage-1 is a root stage
Stage-2 depends on stages: Stage-1, Stage-6
- Stage-5 depends on stages: Stage-2
- Stage-0 depends on stages: Stage-5
+ Stage-5 depends on stages: Stage-2 , consists of Stage-4, Stage-3
+ Stage-4
+ Stage-0 depends on stages: Stage-4, Stage-3
+ Stage-3
Stage-6 is a root stage
- Stage-2 depends on stages: Stage-1, Stage-6
- Stage-5 depends on stages: Stage-2
- Stage-0 depends on stages: Stage-5
STAGE PLANS:
Stage: Stage-1
@@ -85,9 +84,9 @@
type: bigint
Needs Tagging: false
Path -> Alias:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src [null-subquery1:subq1-subquery1:x]
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/src [null-subquery1:subq1-subquery1:x]
Path -> Partition:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/src
Partition
base file name: src
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -102,8 +101,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
- transient_lastDdlTime 1262136633
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/src
+ transient_lastDdlTime 1263595178
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -118,8 +117,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
- transient_lastDdlTime 1262136633
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/src
+ transient_lastDdlTime 1263595178
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: src
name: src
@@ -143,7 +142,7 @@
File Output Operator
compressed: false
GlobalTableId: 0
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10002
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10002
table:
input format: org.apache.hadoop.mapred.SequenceFileInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
@@ -155,7 +154,7 @@
Stage: Stage-2
Map Reduce
Alias -> Map Operator Tree:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10002
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10002
Union
Common Join Operator
condition map:
@@ -163,6 +162,7 @@
condition expressions:
0 {_col1}
1 {key} {value}
+ handleSkewJoin: false
keys:
0 [Column[_col0]]
1 [Column[key]]
@@ -198,7 +198,7 @@
File Output Operator
compressed: false
GlobalTableId: 1
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10003
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10003
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -212,11 +212,11 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136634
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263595178
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10004
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10004
Union
Common Join Operator
condition map:
@@ -224,6 +224,7 @@
condition expressions:
0 {_col1}
1 {key} {value}
+ handleSkewJoin: false
keys:
0 [Column[_col0]]
1 [Column[key]]
@@ -259,7 +260,7 @@
File Output Operator
compressed: false
GlobalTableId: 1
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10003
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10003
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -273,8 +274,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136634
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263595178
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
Local Work:
@@ -293,6 +294,7 @@
condition expressions:
0 {_col1}
1 {key} {value}
+ handleSkewJoin: false
keys:
0 [Column[_col0]]
1 [Column[key]]
@@ -328,7 +330,7 @@
File Output Operator
compressed: false
GlobalTableId: 1
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10003
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10003
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -342,16 +344,16 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136634
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263595178
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
Needs Tagging: false
Path -> Alias:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10002 [file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10002]
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10004 [file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10004]
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10002 [file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10002]
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10004 [file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10004]
Path -> Partition:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10002
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10002
Partition
base file name: 10002
input format: org.apache.hadoop.mapred.SequenceFileInputFormat
@@ -367,7 +369,7 @@
columns _col0,_col1
columns.types string,bigint
escape.delim \
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10004
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10004
Partition
base file name: 10004
input format: org.apache.hadoop.mapred.SequenceFileInputFormat
@@ -386,97 +388,19 @@
Stage: Stage-5
Conditional Operator
- list of dependent Tasks:
- Move Operator
- files:
- hdfs directory: true
- source: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10003
- destination: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/1727788570/10000
- Map Reduce
- Alias -> Map Operator Tree:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10003
- Reduce Output Operator
- sort order:
- Map-reduce partition columns:
- expr: rand()
- type: double
- tag: -1
- value expressions:
- expr: key
- type: string
- expr: value
- type: string
- expr: val2
- type: int
- Needs Tagging: false
- Path -> Alias:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10003 [file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10003]
- Path -> Partition:
- file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10003
- Partition
- base file name: 10003
- input format: org.apache.hadoop.mapred.TextInputFormat
- output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- properties:
- name dest_j1
- columns.types string:string:int
- serialization.ddl struct dest_j1 { string key, string value, i32 val2}
- serialization.format 1
- columns key,value,val2
- bucket_count -1
- serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- file.inputformat org.apache.hadoop.mapred.TextInputFormat
- file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136634
- 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:
- name dest_j1
- columns.types string:string:int
- serialization.ddl struct dest_j1 { string key, string value, i32 val2}
- serialization.format 1
- columns key,value,val2
- bucket_count -1
- serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- file.inputformat org.apache.hadoop.mapred.TextInputFormat
- file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136634
- serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- name: dest_j1
- name: dest_j1
- Reduce Operator Tree:
- Extract
- File Output Operator
- compressed: false
- GlobalTableId: 0
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/1727788570/10000
- table:
- input format: org.apache.hadoop.mapred.TextInputFormat
- output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- properties:
- name dest_j1
- columns.types string:string:int
- serialization.ddl struct dest_j1 { string key, string value, i32 val2}
- serialization.format 1
- columns key,value,val2
- bucket_count -1
- serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- file.inputformat org.apache.hadoop.mapred.TextInputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- transient_lastDdlTime 1262136634
- serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- name: dest_j1
+
+ Stage: Stage-4
+ Move Operator
+ files:
+ hdfs directory: true
+ source: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10003
+ destination: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/604913670/10000
Stage: Stage-0
Move Operator
tables:
replace: true
- source: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/1727788570/10000
+ source: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/604913670/10000
table:
input format: org.apache.hadoop.mapred.TextInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
@@ -490,11 +414,92 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/dest_j1
- transient_lastDdlTime 1262136634
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263595178
+ serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ name: dest_j1
+ tmp directory: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/604913670/10001
+
+ Stage: Stage-3
+ Map Reduce
+ Alias -> Map Operator Tree:
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10003
+ Reduce Output Operator
+ sort order:
+ Map-reduce partition columns:
+ expr: rand()
+ type: double
+ tag: -1
+ value expressions:
+ expr: key
+ type: string
+ expr: value
+ type: string
+ expr: val2
+ type: int
+ Needs Tagging: false
+ Path -> Alias:
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10003 [file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10003]
+ Path -> Partition:
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10003
+ Partition
+ base file name: 10003
+ input format: org.apache.hadoop.mapred.TextInputFormat
+ output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ properties:
+ name dest_j1
+ columns.types string:string:int
+ serialization.ddl struct dest_j1 { string key, string value, i32 val2}
+ serialization.format 1
+ columns key,value,val2
+ bucket_count -1
+ serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ file.inputformat org.apache.hadoop.mapred.TextInputFormat
+ file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263595178
+ 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:
+ name dest_j1
+ columns.types string:string:int
+ serialization.ddl struct dest_j1 { string key, string value, i32 val2}
+ serialization.format 1
+ columns key,value,val2
+ bucket_count -1
+ serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ file.inputformat org.apache.hadoop.mapred.TextInputFormat
+ file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/dest_j1
+ transient_lastDdlTime 1263595178
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
- tmp directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/1727788570/10001
+ name: dest_j1
+ Reduce Operator Tree:
+ Extract
+ File Output Operator
+ compressed: false
+ GlobalTableId: 0
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/604913670/10000
+ table:
+ input format: org.apache.hadoop.mapred.TextInputFormat
+ output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ properties:
+ name dest_j1
+ columns.types string:string:int
+ serialization.ddl struct dest_j1 { string key, string value, i32 val2}
+ serialization.format 1
+ columns key,value,val2
+ bucket_count -1
+ serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ file.inputformat org.apache.hadoop.mapred.TextInputFormat
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/dest_j1
+ file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ transient_lastDdlTime 1263595178
+ serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ name: dest_j1
Stage: Stage-6
Map Reduce
@@ -540,9 +545,9 @@
type: bigint
Needs Tagging: false
Path -> Alias:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src [null-subquery2:subq1-subquery2:x1]
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/src [null-subquery2:subq1-subquery2:x1]
Path -> Partition:
- file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/src
Partition
base file name: src
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -557,8 +562,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
- transient_lastDdlTime 1262136633
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/src
+ transient_lastDdlTime 1263595178
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
input format: org.apache.hadoop.mapred.TextInputFormat
@@ -573,8 +578,8 @@
serialization.lib org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
file.inputformat org.apache.hadoop.mapred.TextInputFormat
file.outputformat org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- location file:/data/users/jsichi/open/hive-trunk/build/ql/test/data/warehouse/src
- transient_lastDdlTime 1262136633
+ location file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/test/data/warehouse/src
+ transient_lastDdlTime 1263595178
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: src
name: src
@@ -598,7 +603,7 @@
File Output Operator
compressed: false
GlobalTableId: 0
- directory: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/2077878187/10004
+ directory: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1737821238/10004
table:
input format: org.apache.hadoop.mapred.SequenceFileInputFormat
output format: org.apache.hadoop.hive.ql.io.HiveSequenceFileOutputFormat
@@ -635,11 +640,11 @@
PREHOOK: query: select * from dest_j1 x order by x.key
PREHOOK: type: QUERY
PREHOOK: Input: default@dest_j1
-PREHOOK: Output: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/102689547/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/942115762/10000
POSTHOOK: query: select * from dest_j1 x order by x.key
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest_j1
-POSTHOOK: Output: file:/data/users/jsichi/open/hive-trunk/build/ql/tmp/102689547/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/942115762/10000
128 3
146 val_146 2
150 val_150 1
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join36.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join36.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join36.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join36.q.out Sat Jan 16 06:44:01 2010
@@ -60,8 +60,10 @@
STAGE DEPENDENCIES:
Stage-1 is a root stage
- Stage-4 depends on stages: Stage-1
- Stage-0 depends on stages: Stage-4
+ Stage-4 depends on stages: Stage-1 , consists of Stage-3, Stage-2
+ Stage-3
+ Stage-0 depends on stages: Stage-3, Stage-2
+ Stage-2
STAGE PLANS:
Stage: Stage-1
@@ -76,6 +78,7 @@
condition expressions:
0 {key} {cnt}
1 {cnt}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[key]]
@@ -123,6 +126,7 @@
condition expressions:
0 {key} {cnt}
1 {cnt}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[key]]
@@ -157,37 +161,12 @@
Stage: Stage-4
Conditional Operator
- list of dependent Tasks:
- Move Operator
- files:
- hdfs directory: true
- destination: file:/data/users/njain/hive5/hive5/build/ql/tmp/288849428/10000
- Map Reduce
- Alias -> Map Operator Tree:
- file:/data/users/njain/hive5/hive5/build/ql/tmp/343369089/10002
- Reduce Output Operator
- sort order:
- Map-reduce partition columns:
- expr: rand()
- type: double
- tag: -1
- value expressions:
- expr: key
- type: int
- expr: value
- type: int
- expr: val2
- type: int
- Reduce Operator Tree:
- Extract
- File Output Operator
- compressed: false
- GlobalTableId: 0
- table:
- input format: org.apache.hadoop.mapred.TextInputFormat
- output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- name: dest_j1
+
+ Stage: Stage-3
+ Move Operator
+ files:
+ hdfs directory: true
+ destination: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/959558219/10000
Stage: Stage-0
Move Operator
@@ -199,6 +178,34 @@
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
+ Stage: Stage-2
+ Map Reduce
+ Alias -> Map Operator Tree:
+ file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1816987590/10002
+ Reduce Output Operator
+ sort order:
+ Map-reduce partition columns:
+ expr: rand()
+ type: double
+ tag: -1
+ value expressions:
+ expr: key
+ type: int
+ expr: value
+ type: int
+ expr: val2
+ type: int
+ Reduce Operator Tree:
+ Extract
+ File Output Operator
+ compressed: false
+ GlobalTableId: 0
+ table:
+ input format: org.apache.hadoop.mapred.TextInputFormat
+ output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ name: dest_j1
+
PREHOOK: query: INSERT OVERWRITE TABLE dest_j1
SELECT /*+ MAPJOIN(x) */ x.key, x.cnt, y.cnt
@@ -217,11 +224,11 @@
PREHOOK: query: select * from dest_j1 x order by x.key
PREHOOK: type: QUERY
PREHOOK: Input: default@dest_j1
-PREHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/1835102638/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1839162600/10000
POSTHOOK: query: select * from dest_j1 x order by x.key
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest_j1
-POSTHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/1835102638/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1839162600/10000
0 3 3
2 1 1
4 1 1
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join37.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join37.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join37.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join37.q.out Sat Jan 16 06:44:01 2010
@@ -22,8 +22,10 @@
STAGE DEPENDENCIES:
Stage-1 is a root stage
- Stage-4 depends on stages: Stage-1
- Stage-0 depends on stages: Stage-4
+ Stage-4 depends on stages: Stage-1 , consists of Stage-3, Stage-2
+ Stage-3
+ Stage-0 depends on stages: Stage-3, Stage-2
+ Stage-2
STAGE PLANS:
Stage: Stage-1
@@ -38,6 +40,7 @@
condition expressions:
0 {key} {value}
1 {value}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[key]]
@@ -94,6 +97,7 @@
condition expressions:
0 {key} {value}
1 {value}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[key]]
@@ -137,37 +141,12 @@
Stage: Stage-4
Conditional Operator
- list of dependent Tasks:
- Move Operator
- files:
- hdfs directory: true
- destination: file:/data/users/njain/hive5/hive5/build/ql/tmp/1084434064/10000
- Map Reduce
- Alias -> Map Operator Tree:
- file:/data/users/njain/hive5/hive5/build/ql/tmp/811526799/10002
- Reduce Output Operator
- sort order:
- Map-reduce partition columns:
- expr: rand()
- type: double
- tag: -1
- value expressions:
- expr: key
- type: int
- expr: value
- type: string
- expr: val2
- type: string
- Reduce Operator Tree:
- Extract
- File Output Operator
- compressed: false
- GlobalTableId: 0
- table:
- input format: org.apache.hadoop.mapred.TextInputFormat
- output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
- serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
- name: dest_j1
+
+ Stage: Stage-3
+ Move Operator
+ files:
+ hdfs directory: true
+ destination: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1631452878/10000
Stage: Stage-0
Move Operator
@@ -179,6 +158,34 @@
serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
name: dest_j1
+ Stage: Stage-2
+ Map Reduce
+ Alias -> Map Operator Tree:
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1071764846/10002
+ Reduce Output Operator
+ sort order:
+ Map-reduce partition columns:
+ expr: rand()
+ type: double
+ tag: -1
+ value expressions:
+ expr: key
+ type: int
+ expr: value
+ type: string
+ expr: val2
+ type: string
+ Reduce Operator Tree:
+ Extract
+ File Output Operator
+ compressed: false
+ GlobalTableId: 0
+ table:
+ input format: org.apache.hadoop.mapred.TextInputFormat
+ output format: org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat
+ serde: org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe
+ name: dest_j1
+
PREHOOK: query: INSERT OVERWRITE TABLE dest_j1
SELECT /*+ MAPJOIN(X) */ x.key, x.value, y.value
@@ -197,11 +204,11 @@
PREHOOK: query: select * from dest_j1 x order by x.key
PREHOOK: type: QUERY
PREHOOK: Input: default@dest_j1
-PREHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/2091374759/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/456566543/10000
POSTHOOK: query: select * from dest_j1 x order by x.key
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest_j1
-POSTHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/2091374759/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/456566543/10000
66 val_66 val_66
98 val_98 val_98
98 val_98 val_98
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join38.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join38.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join38.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join38.q.out Sat Jan 16 06:44:01 2010
@@ -18,11 +18,11 @@
PREHOOK: query: select * from tmp
PREHOOK: type: QUERY
PREHOOK: Input: default@tmp
-PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk-commit/build/ql/tmp/513842932/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/88537684/10000
POSTHOOK: query: select * from tmp
POSTHOOK: type: QUERY
POSTHOOK: Input: default@tmp
-POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk-commit/build/ql/tmp/513842932/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/88537684/10000
100 101 102.0 103.0 104.0 105 106.0 107.0 108.0 109.0 110.0 111
100 101 102.0 103.0 104.0 105 106.0 107.0 108.0 109.0 110.0 111
PREHOOK: query: explain
@@ -62,6 +62,7 @@
condition expressions:
0 {value}
1 {col5} {col11}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[col11]]
@@ -89,6 +90,7 @@
condition expressions:
0 {value}
1 {col5} {col11}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[col11]]
@@ -104,7 +106,7 @@
Stage: Stage-2
Map Reduce
Alias -> Map Operator Tree:
- file:/data/users/heyongqiang/hive-trunk-commit/build/ql/tmp/1670596765/10002
+ file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1516703935/10002
Select Operator
expressions:
expr: _col1
@@ -192,7 +194,7 @@
PREHOOK: type: QUERY
PREHOOK: Input: default@tmp
PREHOOK: Input: default@src
-PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk-commit/build/ql/tmp/1925019467/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/666881903/10000
POSTHOOK: query: FROM src a JOIN tmp b ON (a.key = b.col11)
SELECT /*+ MAPJOIN(a) */ a.value, b.col5, count(1) as count
where b.col11 = 111
@@ -200,7 +202,7 @@
POSTHOOK: type: QUERY
POSTHOOK: Input: default@tmp
POSTHOOK: Input: default@src
-POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk-commit/build/ql/tmp/1925019467/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/666881903/10000
val_111 105 2
PREHOOK: query: drop table tmp
PREHOOK: type: DROPTABLE
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join4.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join4.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join4.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join4.q.out Sat Jan 16 06:44:01 2010
@@ -115,6 +115,7 @@
condition expressions:
0 {VALUE._col0} {VALUE._col1}
1 {VALUE._col0} {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col1, _col2, _col3
Select Operator
expressions:
@@ -204,11 +205,11 @@
PREHOOK: query: SELECT dest1.* FROM dest1
PREHOOK: type: QUERY
PREHOOK: Input: default@dest1
-PREHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/936247839/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1834732501/10000
POSTHOOK: query: SELECT dest1.* FROM dest1
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest1
-POSTHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/936247839/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1834732501/10000
11 val_11 NULL NULL
12 val_12 NULL NULL
12 val_12 NULL NULL
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join40.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join40.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join40.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join40.q.out Sat Jan 16 06:44:01 2010
@@ -71,6 +71,7 @@
condition expressions:
0 {VALUE._col0} {VALUE._col1}
1 {VALUE._col0} {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col1, _col2, _col3
Select Operator
expressions:
@@ -99,12 +100,12 @@
FROM src x left outer JOIN (select * from src where key <= 100) y ON (x.key = y.key)
PREHOOK: type: QUERY
PREHOOK: Input: default@src
-PREHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1575961079/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1249230133/10000
POSTHOOK: query: SELECT x.key, x.value, y.key, y.value
FROM src x left outer JOIN (select * from src where key <= 100) y ON (x.key = y.key)
POSTHOOK: type: QUERY
POSTHOOK: Input: default@src
-POSTHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1575961079/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1249230133/10000
0 val_0 0 val_0
0 val_0 0 val_0
0 val_0 0 val_0
@@ -725,6 +726,7 @@
condition expressions:
0 {VALUE._col0}
1 {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col3
Select Operator
expressions:
@@ -749,12 +751,12 @@
FROM src src1 JOIN src src2 ON (src1.key = src2.key)
PREHOOK: type: QUERY
PREHOOK: Input: default@src
-PREHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1535877066/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1169404066/10000
POSTHOOK: query: select src1.key, src2.value
FROM src src1 JOIN src src2 ON (src1.key = src2.key)
POSTHOOK: type: QUERY
POSTHOOK: Input: default@src
-POSTHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1535877066/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1169404066/10000
0 val_0
0 val_0
0 val_0
@@ -1879,6 +1881,7 @@
0 {VALUE._col0} {VALUE._col1}
1 {VALUE._col0} {VALUE._col1}
2 {VALUE._col0} {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Select Operator
expressions:
@@ -1905,7 +1908,7 @@
Stage: Stage-2
Map Reduce
Alias -> Map Operator Tree:
- file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/448458798/10002
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1836147411/10002
Reduce Output Operator
key expressions:
expr: _col0
@@ -1953,12 +1956,12 @@
SORT BY src1.key, src1.value, src2.key, src2.value, src3.key, src3.value
PREHOOK: type: QUERY
PREHOOK: Input: default@src
-PREHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1868126511/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/561269019/10000
POSTHOOK: query: SELECT * FROM src src1 JOIN src src2 ON (src1.key = src2.key AND src1.key < 10) RIGHT OUTER JOIN src src3 ON (src1.key = src3.key AND src3.key < 20)
SORT BY src1.key, src1.value, src2.key, src2.value, src3.key, src3.value
POSTHOOK: type: QUERY
POSTHOOK: Input: default@src
-POSTHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1868126511/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/561269019/10000
NULL NULL NULL NULL 10 val_10
NULL NULL NULL NULL 11 val_11
NULL NULL NULL NULL 12 val_12
@@ -2131,6 +2134,7 @@
0 {VALUE._col0} {VALUE._col1}
1 {VALUE._col0} {VALUE._col1}
2 {VALUE._col0} {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Select Operator
expressions:
@@ -2157,7 +2161,7 @@
Stage: Stage-2
Map Reduce
Alias -> Map Operator Tree:
- file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/825173402/10002
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1889892039/10002
Reduce Output Operator
key expressions:
expr: _col0
@@ -2205,12 +2209,12 @@
SORT BY src1.key, src1.value, src2.key, src2.value, src3.key, src3.value
PREHOOK: type: QUERY
PREHOOK: Input: default@src
-PREHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1638684247/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1597568732/10000
POSTHOOK: query: SELECT * FROM src src1 JOIN src src2 ON (src1.key = src2.key AND src1.key < 10 AND src2.key < 15) RIGHT OUTER JOIN src src3 ON (src1.key = src3.key AND src3.key < 20)
SORT BY src1.key, src1.value, src2.key, src2.value, src3.key, src3.value
POSTHOOK: type: QUERY
POSTHOOK: Input: default@src
-POSTHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1638684247/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1597568732/10000
NULL NULL NULL NULL 10 val_10
NULL NULL NULL NULL 11 val_11
NULL NULL NULL NULL 12 val_12
@@ -2307,6 +2311,7 @@
condition expressions:
0 {key} {value}
1 {_col0} {_col1}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[_col0]]
@@ -2371,6 +2376,7 @@
condition expressions:
0 {key} {value}
1 {_col0} {_col1}
+ handleSkewJoin: false
keys:
0 [Column[key]]
1 [Column[_col0]]
@@ -2414,12 +2420,12 @@
FROM src x left outer JOIN (select * from src where key <= 100) y ON (x.key = y.key)
PREHOOK: type: QUERY
PREHOOK: Input: default@src
-PREHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/902015943/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/302774741/10000
POSTHOOK: query: SELECT /*+ MAPJOIN(y) */ x.key, x.value, y.key, y.value
FROM src x left outer JOIN (select * from src where key <= 100) y ON (x.key = y.key)
POSTHOOK: type: QUERY
POSTHOOK: Input: default@src
-POSTHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/902015943/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/302774741/10000
238 val_238 NULL NULL
86 val_86 86 val_86
311 val_311 NULL NULL
@@ -3035,6 +3041,7 @@
condition expressions:
0
1
+ handleSkewJoin: false
Select Operator
Group By Operator
aggregations:
@@ -3052,7 +3059,7 @@
Stage: Stage-2
Map Reduce
Alias -> Map Operator Tree:
- file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/1616259380/10002
+ file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1375711979/10002
Reduce Output Operator
sort order:
tag: -1
@@ -3086,9 +3093,9 @@
PREHOOK: query: SELECT COUNT(1) FROM SRC A JOIN SRC B ON (A.KEY=B.KEY)
PREHOOK: type: QUERY
PREHOOK: Input: default@src
-PREHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/623243330/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/991321663/10000
POSTHOOK: query: SELECT COUNT(1) FROM SRC A JOIN SRC B ON (A.KEY=B.KEY)
POSTHOOK: type: QUERY
POSTHOOK: Input: default@src
-POSTHOOK: Output: file:/data/users/nzhang/work/876/apache-hive/build/ql/tmp/623243330/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/991321663/10000
1028
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join5.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join5.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join5.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join5.q.out Sat Jan 16 06:44:01 2010
@@ -115,6 +115,7 @@
condition expressions:
0 {VALUE._col0} {VALUE._col1}
1 {VALUE._col0} {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col1, _col2, _col3
Select Operator
expressions:
@@ -204,11 +205,11 @@
PREHOOK: query: SELECT dest1.* FROM dest1
PREHOOK: type: QUERY
PREHOOK: Input: default@dest1
-PREHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/310187664/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1233073400/10000
POSTHOOK: query: SELECT dest1.* FROM dest1
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest1
-POSTHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/310187664/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1233073400/10000
17 val_17 17 val_17
18 val_18 18 val_18
18 val_18 18 val_18
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join6.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join6.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join6.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join6.q.out Sat Jan 16 06:44:01 2010
@@ -115,6 +115,7 @@
condition expressions:
0 {VALUE._col0} {VALUE._col1}
1 {VALUE._col0} {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col1, _col2, _col3
Select Operator
expressions:
@@ -204,11 +205,11 @@
PREHOOK: query: SELECT dest1.* FROM dest1
PREHOOK: type: QUERY
PREHOOK: Input: default@dest1
-PREHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/990359387/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1206114347/10000
POSTHOOK: query: SELECT dest1.* FROM dest1
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest1
-POSTHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/990359387/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_0/build/ql/tmp/1206114347/10000
11 val_11 NULL NULL
12 val_12 NULL NULL
12 val_12 NULL NULL
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join7.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join7.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join7.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join7.q.out Sat Jan 16 06:44:01 2010
@@ -159,6 +159,7 @@
0 {VALUE._col0} {VALUE._col1}
1 {VALUE._col0} {VALUE._col1}
2 {VALUE._col0} {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col1, _col2, _col3, _col4, _col5
Select Operator
expressions:
@@ -270,11 +271,11 @@
PREHOOK: query: SELECT dest1.* FROM dest1
PREHOOK: type: QUERY
PREHOOK: Input: default@dest1
-PREHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/1362605307/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1490522994/10000
POSTHOOK: query: SELECT dest1.* FROM dest1
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest1
-POSTHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/1362605307/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_1/build/ql/tmp/1490522994/10000
11 val_11 NULL NULL NULL NULL
12 val_12 NULL NULL NULL NULL
12 val_12 NULL NULL NULL NULL
Modified: hadoop/hive/trunk/ql/src/test/results/clientpositive/join8.q.out
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/test/results/clientpositive/join8.q.out?rev=899891&r1=899890&r2=899891&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/test/results/clientpositive/join8.q.out (original)
+++ hadoop/hive/trunk/ql/src/test/results/clientpositive/join8.q.out Sat Jan 16 06:44:01 2010
@@ -115,6 +115,7 @@
condition expressions:
0 {VALUE._col0} {VALUE._col1}
1 {VALUE._col0} {VALUE._col1}
+ handleSkewJoin: false
outputColumnNames: _col0, _col1, _col2, _col3
Select Operator
expressions:
@@ -208,11 +209,11 @@
PREHOOK: query: SELECT dest1.* FROM dest1
PREHOOK: type: QUERY
PREHOOK: Input: default@dest1
-PREHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/1940291969/10000
+PREHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1413469153/10000
POSTHOOK: query: SELECT dest1.* FROM dest1
POSTHOOK: type: QUERY
POSTHOOK: Input: default@dest1
-POSTHOOK: Output: file:/data/users/njain/hive5/hive5/build/ql/tmp/1940291969/10000
+POSTHOOK: Output: file:/data/users/heyongqiang/hive-trunk/.ptest_2/build/ql/tmp/1413469153/10000
11 val_11 NULL NULL
12 val_12 NULL NULL
12 val_12 NULL NULL