hadoop-hive-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From John Sichi <jsi...@facebook.com>
Subject Re: load_dyn_part2.q on Hadoop 17
Date Thu, 29 Jul 2010 23:57:14 GMT
I only ran clean in between, not clean-test.  But the test target depends on clean-test, so
I don't think doing that explicitly would have made a difference.

JVS

On Jul 29, 2010, at 4:51 PM, Ning Zhang wrote:

> Did you run ant clean clean-test after 20 and before 17? If no some tests later than
load_dyn_part2 could changed srcpart.
>
> On Jul 29, 2010, at 4:40 PM, John Sichi wrote:
>
>> Yes, it passed for me just now when run in isolation.
>>
>> I wonder why it passed on the first full test run (on Hadoop 20), but then failed
when I re-ran against 17.
>>
>> JVS
>>
>> On Jul 29, 2010, at 4:11 PM, Ning Zhang wrote:
>>
>>> John, it works for me when running this test alone. One thing I noticed is that
the result you got have additional partitions (hr=13..19). This can be explained by the srcpart
was changed (additional partitioned added by other tests). Since now we don't clean up the
srcpart tables for each .q file, the side effects of previous .q files could remain. Can you
check if you can get the correct results by testing this .q file alone?
>>>
>>>
>>> On Jul 29, 2010, at 1:08 PM, John Sichi wrote:
>>>
>>>> I just hit a test failure with this on latest trunk (while testing out a
patch); see diff output below.  Do you know if this broke recently?  Same code passed on Hadoop
20.
>>>>
>>>> JVS
>>>>
>>>> ----
>>>>
>>>> [jsichi@dev578 ~/open/commit-trunk] diff ql/src/test/results/clientpositive/load_dyn_part2.q.out
build/ql/test/logs/clientpositive/load_dyn_part2.q.out
>>>> --- ql/src/test/results/clientpositive/load_dyn_part2.q.out     2010-07-28
23:16:54.000000000 -0700
>>>> +++ build/ql/test/logs/clientpositive/load_dyn_part2.q.out      2010-07-29
09:57:13.000000000 -0700
>>>> @@ -16,7 +16,7 @@
>>>> ds     string
>>>> hr     string
>>>>
>>>> -Detailed Table Information     Table(tableName:nzhang_part_bucket, dbName:default,
owner:jssarma, createTime:1279737530, lastAccessTime:0, retention:0, sd:StorageDescriptor(cols:[FieldSchema(name:key,
type:string, comment:null), FieldSchema(name:value, type:string, comment:null)], location:file:/mnt/vol/devrs004.snc1/jssarma/projects/hive_trunk/build/ql/test/data/warehouse/nzhang_part_bucket,
inputFormat:org.apache.hadoop.mapred.TextInputFormat, outputFormat:org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat,
compressed:false, numBuckets:10, serdeInfo:SerDeInfo(name:null, serializationLib:org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe,
parameters:{serialization.format=1}), bucketCols:[key], sortCols:[], parameters:{}), partitionKeys:[FieldSchema(name:ds,
type:string, comment:null), FieldSchema(name:hr, type:string, comment:null)], parameters:{transient_lastDdlTime=1279737530},
viewOriginalText:null, viewExpandedText:null, tableType:MANAGED_TABLE)
>>>> +Detailed Table Information     Table(tableName:nzhang_part_bucket, dbName:default,
owner:jsichi, createTime:1280422615, lastAccessTime:0, retention:0, sd:StorageDescriptor(cols:[FieldSchema(name:key,
type:string, comment:null), FieldSchema(name:value, type:string, comment:null)], location:pfile:/data/users/jsichi/open/commit-trunk/build/ql/test/data/warehouse/nzhang_part_bucket,
inputFormat:org.apache.hadoop.mapred.TextInputFormat, outputFormat:org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat,
compressed:false, numBuckets:10, serdeInfo:SerDeInfo(name:null, serializationLib:org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe,
parameters:{serialization.format=1}), bucketCols:[key], sortCols:[], parameters:{}), partitionKeys:[FieldSchema(name:ds,
type:string, comment:null), FieldSchema(name:hr, type:string, comment:null)], parameters:{transient_lastDdlTime=1280422615},
viewOriginalText:null, viewExpandedText:null, tableType:MANAGED_TABLE)
>>>> PREHOOK: query: explain
>>>> insert overwrite table nzhang_part_bucket partition (ds='2010-03-23', hr)
select key, value, hr from srcpart where ds is not null and hr is not null
>>>> PREHOOK: type: QUERY
>>>> @@ -104,34 +104,98 @@
>>>> POSTHOOK: Input: default@srcpart@ds=2008-04-08/hr=12
>>>> POSTHOOK: Input: default@srcpart@ds=2008-04-09/hr=11
>>>> POSTHOOK: Input: default@srcpart@ds=2008-04-09/hr=12
>>>> +POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=10
>>>> POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=11
>>>> POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=12
>>>> +POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=13
>>>> +POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=14
>>>> +POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=15
>>>> +POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=16
>>>> +POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=17
>>>> +POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=18
>>>> +POSTHOOK: Output: default@nzhang_part_bucket@ds=2010-03-23/hr=19
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=10).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=10).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=11).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=11).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=12).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=12).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=13).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=13).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=14).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=14).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=15).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=15).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=16).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=16).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=17).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=17).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=18).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=18).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=19).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=19).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> PREHOOK: query: show partitions nzhang_part_bucket
>>>> PREHOOK: type: SHOWPARTITIONS
>>>> POSTHOOK: query: show partitions nzhang_part_bucket
>>>> POSTHOOK: type: SHOWPARTITIONS
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=10).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=10).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=11).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=11).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=12).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=12).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=13).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=13).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=14).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=14).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=15).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=15).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=16).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=16).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=17).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=17).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=18).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=18).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=19).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=19).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +ds=2010-03-23/hr=10
>>>> ds=2010-03-23/hr=11
>>>> ds=2010-03-23/hr=12
>>>> +ds=2010-03-23/hr=13
>>>> +ds=2010-03-23/hr=14
>>>> +ds=2010-03-23/hr=15
>>>> +ds=2010-03-23/hr=16
>>>> +ds=2010-03-23/hr=17
>>>> +ds=2010-03-23/hr=18
>>>> +ds=2010-03-23/hr=19
>>>> PREHOOK: query: select * from nzhang_part_bucket where ds='2010-03-23' and
hr='11' order by key
>>>> PREHOOK: type: QUERY
>>>> PREHOOK: Input: default@nzhang_part_bucket@ds=2010-03-23/hr=11
>>>> -PREHOOK: Output: file:/tmp/jssarma/hive_2010-07-21_11-38-55_332_7977928498639952021/10000
>>>> +PREHOOK: Output: file:/tmp/jsichi/hive_2010-07-29_09-57-06_280_5053278566922695787/-mr-10000
>>>> POSTHOOK: query: select * from nzhang_part_bucket where ds='2010-03-23' and
hr='11' order by key
>>>> POSTHOOK: type: QUERY
>>>> POSTHOOK: Input: default@nzhang_part_bucket@ds=2010-03-23/hr=11
>>>> -POSTHOOK: Output: file:/tmp/jssarma/hive_2010-07-21_11-38-55_332_7977928498639952021/10000
>>>> +POSTHOOK: Output: file:/tmp/jsichi/hive_2010-07-29_09-57-06_280_5053278566922695787/-mr-10000
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=10).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=10).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=11).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=11).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=12).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=12).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=13).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=13).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=14).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=14).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=15).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=15).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=16).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=16).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=17).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=17).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=18).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=18).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=19).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=19).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> 0      val_0   2010-03-23      11
>>>> 0      val_0   2010-03-23      11
>>>> 0      val_0   2010-03-23      11
>>>> @@ -1135,15 +1199,31 @@
>>>> PREHOOK: query: select * from nzhang_part_bucket where ds='2010-03-23' and
hr='12' order by key
>>>> PREHOOK: type: QUERY
>>>> PREHOOK: Input: default@nzhang_part_bucket@ds=2010-03-23/hr=12
>>>> -PREHOOK: Output: file:/tmp/jssarma/hive_2010-07-21_11-39-00_003_5219381574950480620/10000
>>>> +PREHOOK: Output: file:/tmp/jsichi/hive_2010-07-29_09-57-10_596_5004906641941964206/-mr-10000
>>>> POSTHOOK: query: select * from nzhang_part_bucket where ds='2010-03-23' and
hr='12' order by key
>>>> POSTHOOK: type: QUERY
>>>> POSTHOOK: Input: default@nzhang_part_bucket@ds=2010-03-23/hr=12
>>>> -POSTHOOK: Output: file:/tmp/jssarma/hive_2010-07-21_11-39-00_003_5219381574950480620/10000
>>>> +POSTHOOK: Output: file:/tmp/jsichi/hive_2010-07-29_09-57-10_596_5004906641941964206/-mr-10000
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=10).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=10).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=11).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=11).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=12).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=12).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=13).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=13).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=14).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=14).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=15).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=15).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=16).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=16).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=17).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=17).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=18).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=18).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=19).key
SIMPLE [(srcpart)srcpart.FieldSchema(name:ds, type:string, comment:null), ]
>>>> +POSTHOOK: Lineage: nzhang_part_bucket PARTITION(ds=2010-03-23,hr=19).value
SIMPLE [(srcpart)srcpart.FieldSchema(name:hr, type:string, comment:null), ]
>>>> 0      val_0   2010-03-23      12
>>>> 0      val_0   2010-03-23      12
>>>> 0      val_0   2010-03-23      12
>>>>
>>>
>>
>


Mime
View raw message