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 2026/04/02 10:23:36 UTC
Re: [PR] [HUDI-1109] Support Spark Structured Streaming read from Hudi table [hudi]
codecov-commenter commented on PR #2485:
URL: https://github.com/apache/hudi/pull/2485#issuecomment-4176208459
## [Codecov](https://app.codecov.io/gh/apache/hudi/pull/2485?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) Report
:x: Patch coverage is `64.51613%` with `44 lines` in your changes missing coverage. Please review.
:white_check_mark: Project coverage is 51.01%. Comparing base ([`5d053b4`](https://app.codecov.io/gh/apache/hudi/commit/5d053b495b8cb44cce88a67e82cbdfdc3d8b3180?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)) to head ([`56a0ae1`](https://app.codecov.io/gh/apache/hudi/commit/56a0ae1c8e74c7f3aff8f2eba84768be0139c32c?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)).
:warning: Report is 5894 commits behind head on master.
| [Files with missing lines](https://app.codecov.io/gh/apache/hudi/pull/2485?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Patch % | Lines |
|---|---|---|
| [.../spark/sql/hudi/streaming/HoodieStreamSource.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fspark%2Fsql%2Fhudi%2Fstreaming%2FHoodieStreamSource.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3Bhcmsvc3JjL21haW4vc2NhbGEvb3JnL2FwYWNoZS9zcGFyay9zcWwvaHVkaS9zdHJlYW1pbmcvSG9vZGllU3RyZWFtU291cmNlLnNjYWxh) | 68.67% | [11 Missing and 15 partials :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [.../spark/sql/hudi/streaming/HoodieSourceOffset.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fspark%2Fsql%2Fhudi%2Fstreaming%2FHoodieSourceOffset.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3Bhcmsvc3JjL21haW4vc2NhbGEvb3JnL2FwYWNoZS9zcGFyay9zcWwvaHVkaS9zdHJlYW1pbmcvSG9vZGllU291cmNlT2Zmc2V0LnNjYWxh) | 63.15% | [4 Missing and 3 partials :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...src/main/scala/org/apache/hudi/DefaultSource.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fhudi%2FDefaultSource.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3Bhcmsvc3JjL21haW4vc2NhbGEvb3JnL2FwYWNoZS9odWRpL0RlZmF1bHRTb3VyY2Uuc2NhbGE=) | 64.28% | [4 Missing and 1 partial :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...rc/main/scala/org/apache/hudi/Spark3RowSerDe.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark3%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fhudi%2FSpark3RowSerDe.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3BhcmszL3NyYy9tYWluL3NjYWxhL29yZy9hcGFjaGUvaHVkaS9TcGFyazNSb3dTZXJEZS5zY2FsYQ==) | 0.00% | [3 Missing :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [...rc/main/scala/org/apache/hudi/Spark2RowSerDe.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark2%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fhudi%2FSpark2RowSerDe.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3BhcmsyL3NyYy9tYWluL3NjYWxhL29yZy9hcGFjaGUvaHVkaS9TcGFyazJSb3dTZXJEZS5zY2FsYQ==) | 0.00% | [2 Missing :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) |
| [.../main/scala/org/apache/hudi/HoodieSparkUtils.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fhudi%2FHoodieSparkUtils.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3Bhcmsvc3JjL21haW4vc2NhbGEvb3JnL2FwYWNoZS9odWRpL0hvb2RpZVNwYXJrVXRpbHMuc2NhbGE=) | 66.66% | [1 Missing :warning: ](https://app.codecov.io/gh/apache/hudi/pull/2485?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/2485?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
```diff
@@ Coverage Diff @@
## master #2485 +/- ##
============================================
+ Coverage 49.78% 51.01% +1.22%
- Complexity 3089 3197 +108
============================================
Files 430 435 +5
Lines 19566 19925 +359
Branches 2004 2047 +43
============================================
+ Hits 9741 10164 +423
+ Misses 9033 8925 -108
- Partials 792 836 +44
```
| [Flag](https://app.codecov.io/gh/apache/hudi/pull/2485/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/2485/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `36.90% <ø> (-0.31%)` | :arrow_down: |
| [hudiclient](https://app.codecov.io/gh/apache/hudi/pull/2485/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/2485/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `51.38% <ø> (-0.12%)` | :arrow_down: |
| [hudiflink](https://app.codecov.io/gh/apache/hudi/pull/2485/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `43.21% <ø> (+10.17%)` | :arrow_up: |
| [hudihadoopmr](https://app.codecov.io/gh/apache/hudi/pull/2485/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/2485/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `69.48% <64.51%> (-0.03%)` | :arrow_down: |
| [hudisync](https://app.codecov.io/gh/apache/hudi/pull/2485/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `48.61% <ø> (ø)` | |
| [huditimelineservice](https://app.codecov.io/gh/apache/hudi/pull/2485/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/2485/flags?src=pr&el=flag&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | `69.46% <ø> (+7.60%)` | :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/2485?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) | Coverage Δ | |
|---|---|---|
| [.../main/scala/org/apache/hudi/HoodieSparkUtils.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fhudi%2FHoodieSparkUtils.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3Bhcmsvc3JjL21haW4vc2NhbGEvb3JnL2FwYWNoZS9odWRpL0hvb2RpZVNwYXJrVXRpbHMuc2NhbGE=) | `88.88% <66.66%> (ø)` | |
| [...rc/main/scala/org/apache/hudi/Spark2RowSerDe.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark2%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fhudi%2FSpark2RowSerDe.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3BhcmsyL3NyYy9tYWluL3NjYWxhL29yZy9hcGFjaGUvaHVkaS9TcGFyazJSb3dTZXJEZS5zY2FsYQ==) | `0.00% <0.00%> (ø)` | |
| [...rc/main/scala/org/apache/hudi/Spark3RowSerDe.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark3%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fhudi%2FSpark3RowSerDe.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3BhcmszL3NyYy9tYWluL3NjYWxhL29yZy9hcGFjaGUvaHVkaS9TcGFyazNSb3dTZXJEZS5zY2FsYQ==) | `0.00% <0.00%> (ø)` | |
| [...src/main/scala/org/apache/hudi/DefaultSource.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fhudi%2FDefaultSource.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3Bhcmsvc3JjL21haW4vc2NhbGEvb3JnL2FwYWNoZS9odWRpL0RlZmF1bHRTb3VyY2Uuc2NhbGE=) | `84.21% <64.28%> (-4.50%)` | :arrow_down: |
| [.../spark/sql/hudi/streaming/HoodieSourceOffset.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fspark%2Fsql%2Fhudi%2Fstreaming%2FHoodieSourceOffset.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3Bhcmsvc3JjL21haW4vc2NhbGEvb3JnL2FwYWNoZS9zcGFyay9zcWwvaHVkaS9zdHJlYW1pbmcvSG9vZGllU291cmNlT2Zmc2V0LnNjYWxh) | `63.15% <63.15%> (ø)` | |
| [.../spark/sql/hudi/streaming/HoodieStreamSource.scala](https://app.codecov.io/gh/apache/hudi/pull/2485?src=pr&el=tree&filepath=hudi-spark-datasource%2Fhudi-spark%2Fsrc%2Fmain%2Fscala%2Forg%2Fapache%2Fspark%2Fsql%2Fhudi%2Fstreaming%2FHoodieStreamSource.scala&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-aHVkaS1zcGFyay1kYXRhc291cmNlL2h1ZGktc3Bhcmsvc3JjL21haW4vc2NhbGEvb3JnL2FwYWNoZS9zcGFyay9zcWwvaHVkaS9zdHJlYW1pbmcvSG9vZGllU3RyZWFtU291cmNlLnNjYWxh) | `68.67% <68.67%> (ø)` | |
... and [31 files with indirect coverage changes](https://app.codecov.io/gh/apache/hudi/pull/2485/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