You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "codecov-commenter (via GitHub)" <gi...@apache.org> on 2025/06/11 03:29:12 UTC
Re: [PR] [HUDI-1632] Supports merge on read write mode for Flink writer [hudi]
codecov-commenter commented on PR #2593:
URL: https://github.com/apache/hudi/pull/2593#issuecomment-2961136560
## [Codecov](https://app.codecov.io/gh/apache/hudi/pull/2593?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) Report
Attention: Patch coverage is `81.06796%` with `39 lines` in your changes missing coverage. Please review.
> Project coverage is 51.57%. Comparing base [(`06dc7c7`)](https://app.codecov.io/gh/apache/hudi/commit/06dc7c7fd8a867a1e1da90f7dc19b0cc2da69bba?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) to head [(`c22ac8d`)](https://app.codecov.io/gh/apache/hudi/commit/c22ac8d412b54fe185ed8cd46b3fce5aedaba142?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
> Report is 5056 commits behind head on master.
| [Files with missing lines](https://app.codecov.io/gh/apache/hudi/pull/2593?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Patch % | Lines |
|---|---|---|
| [...he/hudi/operator/compact/CompactionCommitSink.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fcompact%2FCompactionCommitSink.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9jb21wYWN0L0NvbXBhY3Rpb25Db21taXRTaW5rLmphdmE=) | 70.21% | [11 Missing and 3 partials :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...perator/partitioner/delta/DeltaBucketAssigner.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fpartitioner%2Fdelta%2FDeltaBucketAssigner.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9wYXJ0aXRpb25lci9kZWx0YS9EZWx0YUJ1Y2tldEFzc2lnbmVyLmphdmE=) | 68.42% | [7 Missing and 5 partials :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [.../hudi/operator/compact/CompactionPlanOperator.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fcompact%2FCompactionPlanOperator.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9jb21wYWN0L0NvbXBhY3Rpb25QbGFuT3BlcmF0b3IuamF2YQ==) | 79.06% | [5 Missing and 4 partials :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...che/hudi/operator/partitioner/BucketAssigners.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fpartitioner%2FBucketAssigners.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9wYXJ0aXRpb25lci9CdWNrZXRBc3NpZ25lcnMuamF2YQ==) | 50.00% | [1 Missing and 1 partial :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [.../hudi/operator/StreamWriteOperatorCoordinator.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2FStreamWriteOperatorCoordinator.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9TdHJlYW1Xcml0ZU9wZXJhdG9yQ29vcmRpbmF0b3IuamF2YQ==) | 85.71% | [0 Missing and 1 partial :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...e/hudi/operator/compact/CompactionCommitEvent.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fcompact%2FCompactionCommitEvent.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9jb21wYWN0L0NvbXBhY3Rpb25Db21taXRFdmVudC5qYXZh) | 87.50% | [1 Missing :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
<details><summary>Additional details and impacted files</summary>
[](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
```diff
@@ Coverage Diff @@
## master #2593 +/- ##
============================================
+ Coverage 51.22% 51.57% +0.35%
- Complexity 3230 3287 +57
============================================
Files 438 445 +7
Lines 20093 20328 +235
Branches 2069 2102 +33
============================================
+ Hits 10292 10484 +192
- Misses 8954 8978 +24
- Partials 847 866 +19
```
| [Flag](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flags&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Coverage Δ | |
|---|---|---|
| [hudicli](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `36.87% <ø> (ø)` | |
| [hudiclient](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `∅ <ø> (∅)` | |
| [hudicommon](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `51.33% <ø> (-0.03%)` | :arrow_down: |
| [hudiflink](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `51.39% <81.06%> (+4.53%)` | :arrow_up: |
| [hudihadoopmr](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `33.16% <ø> (ø)` | |
| [hudisparkdatasource](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `69.71% <ø> (-0.05%)` | :arrow_down: |
| [hudisync](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `49.62% <ø> (+1.00%)` | :arrow_up: |
| [huditimelineservice](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `66.49% <ø> (ø)` | |
| [hudiutilities](https://app.codecov.io/gh/apache/hudi/pull/2593/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `69.59% <ø> (+0.08%)` | :arrow_up: |
Flags with carried forward coverage won't be shown. [Click here](https://docs.codecov.io/docs/carryforward-flags?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#carryforward-flags-in-the-pull-request-comment) to find out more.
| [Files with missing lines](https://app.codecov.io/gh/apache/hudi/pull/2593?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Coverage Δ | |
|---|---|---|
| [...in/java/org/apache/hudi/operator/FlinkOptions.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2FFlinkOptions.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9GbGlua09wdGlvbnMuamF2YQ==) | `78.57% <100.00%> (+3.57%)` | :arrow_up: |
| [.../org/apache/hudi/operator/StreamWriteFunction.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2FStreamWriteFunction.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9TdHJlYW1Xcml0ZUZ1bmN0aW9uLmphdmE=) | `86.59% <100.00%> (+0.28%)` | :arrow_up: |
| [.../apache/hudi/operator/compact/CompactFunction.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fcompact%2FCompactFunction.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9jb21wYWN0L0NvbXBhY3RGdW5jdGlvbi5qYXZh) | `100.00% <100.00%> (ø)` | |
| [...che/hudi/operator/compact/CompactionPlanEvent.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fcompact%2FCompactionPlanEvent.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9jb21wYWN0L0NvbXBhY3Rpb25QbGFuRXZlbnQuamF2YQ==) | `100.00% <100.00%> (ø)` | |
| [...udi/operator/partitioner/BucketAssignFunction.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fpartitioner%2FBucketAssignFunction.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9wYXJ0aXRpb25lci9CdWNrZXRBc3NpZ25GdW5jdGlvbi5qYXZh) | `84.94% <100.00%> (+0.16%)` | :arrow_up: |
| [...ache/hudi/operator/partitioner/BucketAssigner.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fpartitioner%2FBucketAssigner.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9wYXJ0aXRpb25lci9CdWNrZXRBc3NpZ25lci5qYXZh) | `80.17% <ø> (ø)` | |
| [...c/main/java/org/apache/hudi/util/StreamerUtil.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Futil%2FStreamerUtil.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS91dGlsL1N0cmVhbWVyVXRpbC5qYXZh) | `42.59% <100.00%> (+2.20%)` | :arrow_up: |
| [.../hudi/operator/StreamWriteOperatorCoordinator.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2FStreamWriteOperatorCoordinator.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9TdHJlYW1Xcml0ZU9wZXJhdG9yQ29vcmRpbmF0b3IuamF2YQ==) | `70.18% <85.71%> (+0.70%)` | :arrow_up: |
| [...e/hudi/operator/compact/CompactionCommitEvent.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fcompact%2FCompactionCommitEvent.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9jb21wYWN0L0NvbXBhY3Rpb25Db21taXRFdmVudC5qYXZh) | `87.50% <87.50%> (ø)` | |
| [...che/hudi/operator/partitioner/BucketAssigners.java](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree&filepath=hudi-flink%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Fhudi%2Foperator%2Fpartitioner%2FBucketAssigners.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1mbGluay9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvaHVkaS9vcGVyYXRvci9wYXJ0aXRpb25lci9CdWNrZXRBc3NpZ25lcnMuamF2YQ==) | `50.00% <50.00%> (ø)` | |
| ... and [3 more](https://app.codecov.io/gh/apache/hudi/pull/2593?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | |
... and [8 files with indirect coverage changes](https://app.codecov.io/gh/apache/hudi/pull/2593/indirect-changes?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
</details>
<details><summary> :rocket: New features to boost your workflow: </summary>
- :snowflake: [Test Analytics](https://docs.codecov.com/docs/test-analytics): Detect flaky tests, report on failures, and find test suite problems.
</details>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org