[HIVE-22098] Data loss occurs when multiple tables are join with different bucket_version

• Type: Bug
• Status: Patch Available
• Priority: Blocker
• Resolution: Unresolved
• Affects Version/s: 3.1.0, 3.1.2
• Component/s: Operators
• Labels: data-loss wrongresults
• Target Version/s: 3.1.0
• Assignee: Unassigned
• Reporter: GuangMing Lu
• Created: 12/Aug/19 08:17
• Updated: 26/Sep/23 07:48

Description

When different bucketVersion of tables do join and no of reducers is greater than 2, the result is incorrect (data loss).
Scenario 1: Three tables join. The temporary result data of table_a in the first table and table_b in the second table joins result is recorded as tmp_a_b, When it joins with the third table, the bucket_version=2 of the table created by default after hive-3.0.0, temporary data tmp_a_b initialized the bucketVerison=-1, and then ReduceSinkOperator Verketison=-1 is joined. In the init method, the hash algorithm of selecting join column is selected according to bucketVersion. If bucketVersion = 2 and is not an acid operation, it will acquired the new algorithm of hash. Otherwise, the old algorithm of hash is acquired. Because of the inconsistency of the algorithm of hash, the partition of data allocation caused are different. At stage of Reducer, Data with the same key can not be paired resulting in data loss.

Scenario 2: create two test tables, create table table_bucketversion_1(col_1 string, col_2 string) TBLPROPERTIES ('bucketing_version'='1'); table_bucketversion_2(col_1 string, col_2 string) TBLPROPERTIES ('bucketing_version'='2');
when use table_bucketversion_1 to join table_bucketversion_2, partial result data will be loss due to bucketVerison is different.

 

Issue Links

• is fixed by: HIVE-21304 Make bucketing version usage more robust
• is related to: HIVE-18735 Create table like loses transactional attribute
• is related to: HIVE-23809 Data loss occurs when using tez engine to join different bucketing_version tables
• relates to: HIVE-18983 Add support for table properties inheritance in Create table like