Spark batch ingestion common code abstraction.#14415
Spark batch ingestion common code abstraction.#14415Jackie-Jiang merged 4 commits intoapache:masterfrom
Conversation
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #14415 +/- ##
============================================
+ Coverage 61.75% 63.99% +2.24%
- Complexity 207 1572 +1365
============================================
Files 2436 2690 +254
Lines 133233 147898 +14665
Branches 20636 22667 +2031
============================================
+ Hits 82274 94653 +12379
- Misses 44911 46311 +1400
- Partials 6048 6934 +886
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
7a9dbcf to
121c1c8
Compare
Jackie-Jiang
left a comment
There was a problem hiding this comment.
Thanks for the cleanup! Didn't go over the changes in detail. Is the new code identical to the old?
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-spark-base/pom.xml
Outdated
Show resolved
Hide resolved
pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-spark-2.4/pom.xml
Outdated
Show resolved
Hide resolved
...in/java/org/apache/pinot/plugin/ingestion/batch/spark/SparkSegmentMetadataPushJobRunner.java
Outdated
Show resolved
Hide resolved
...che/pinot/plugin/ingestion/batch/spark/common/AbstractSparkSegmentMetadataPushJobRunner.java
Outdated
Show resolved
Hide resolved
121c1c8 to
c6d263c
Compare
|
@jadami10 Are you using the spark job for the batch ingestion? It would be good if you can help review this PR |
jadami10
left a comment
There was a problem hiding this comment.
this seems right. From what I can tell, it's just code moving.
curious why you're not doing SparkSegmentGenerationJobRunner.java and SparkSegmentMetadataPushJobRunner.java.
Yes, it's just a common code movement; no change in logic. It's also there for |
|
Can i get some review on this? Thanks |
As per the issue, this code abstracts the common code from the Spark 2.4 and Spark 3 modules into common code.