[SUPPORT] The INSERT records are marked as UPDATE
- Dominant language
- Java
- Stars
- 6.2k
- Forks
- 2.5k
- Avg merge
- 2d 8h
- Merged PRs (30d)
- 111
Description
When inserting a record to a MOR table, trying to assign a bucket for the record
So, at last, the INSERT record will be marked as an UPDATE in the .deltacommit file, is it reasonable? I'll appreciate it if any one can give me a hand.
* Hudi version : 0.13.1
* Flink version : 1.14
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by reproducing the behavior with Hudi 0.13.1 and Flink 1.14 on a MOR table while assigning a bucket. Inspect the resulting .deltacommit file and compare the recorded INSERT and UPDATE classifications; done means determining whether the INSERT being marked as UPDATE is expected or identifying the relevant behavior to correct.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- data-engineering, stream-processing
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100