Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.0.1
-
None
Description
HIVE-11983 adds ObjectInspectorUtils.getBucketHashCode() and getBucketNumber().
There are several (at least) places in Hive that perform this computation:
- ReduceSinkOperator.computeBucketNumber
- ReduceSinkOperator.computeHashCode
- BucketIdResolverImpl - only in 2.0.0 ASF line
- FileSinkOperator.findWriterOffset
- GenericUDFHash
Should refactor it and make sure they all call methods from ObjectInspectorUtils.
Attachments
Attachments
Issue Links
- is blocked by
-
HIVE-11983 Hive streaming API uses incorrect logic to assign buckets to incoming records
- Resolved