Skip to content

[BLAZE-1137] Extracting celeborn/uniffle/paimon code to seperated modules#1136

Merged
richox merged 6 commits intoapache:masterfrom
turboFei:third_party
Aug 14, 2025
Merged

[BLAZE-1137] Extracting celeborn/uniffle/paimon code to seperated modules#1136
richox merged 6 commits intoapache:masterfrom
turboFei:third_party

Conversation

@turboFei
Copy link
Member

@turboFei turboFei commented Aug 9, 2025

Which issue does this PR close?

Closes #1137

Rationale for this change

Address comment: #1124 (comment)

i'm thinking about extracting these 3rdparty components (celeborn, uniffle, paimon etc) to separated packages, then users can build with specified components for their environments, like build/mvn -Prelease -Pspark-3.5 -Pceleborn-0.6

What changes are included in this PR?

Are there any user-facing changes?

No.

@turboFei turboFei force-pushed the third_party branch 5 times, most recently from 3732896 to d2ff92b Compare August 10, 2025 00:05
@turboFei turboFei changed the title Extracting celeborn/uniffle/paimon code to seperated modules [BLAZE-1137] Extracting celeborn/uniffle/paimon code to seperated modules Aug 10, 2025
@turboFei turboFei force-pushed the third_party branch 4 times, most recently from e9a438c to cd520ad Compare August 10, 2025 02:40
@turboFei turboFei requested a review from richox August 11, 2025 03:38
Copy link
Member

@wForget wForget left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

@richox
Copy link
Contributor

richox commented Aug 11, 2025

i think this pr is no longer needed after modules separated: #1124

@turboFei
Copy link
Member Author

turboFei commented Aug 11, 2025

i think this pr is no longer needed after modules separated: #1124

Do you mean we only support celeborn-0.6 officially?

I am fine ether support celeborn-0.6 officially only.

or use different source path for celeborn-0.5 and celeborn 0.6.

src/main/scala
src/main/celeborn-0.5
src/main/celeborn-0.6

@turboFei turboFei closed this Aug 12, 2025
@turboFei turboFei reopened this Aug 12, 2025
@turboFei turboFei closed this Aug 12, 2025
@turboFei turboFei reopened this Aug 12, 2025
@turboFei
Copy link
Member Author

unrelated GA failure, will try GA later
image

@turboFei turboFei closed this Aug 12, 2025
@turboFei turboFei reopened this Aug 12, 2025
@turboFei turboFei closed this Aug 12, 2025
@turboFei turboFei reopened this Aug 12, 2025
@turboFei turboFei closed this Aug 12, 2025
@turboFei turboFei reopened this Aug 12, 2025
@turboFei
Copy link
Member Author

rebased the code

@richox richox merged commit 2b15738 into apache:master Aug 14, 2025
224 of 276 checks passed
@turboFei turboFei deleted the third_party branch August 14, 2025 17:03
</profile>

<profile>
<id>celeborn-0.5</id>
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It seems that using this profile will fail to compile. Do we have any plans to support it? Or only the latest version is supported

BlazeCelebornShuffleReader.scala:65: one more argument than can be applied to constructor CelebornShuffleReader: (handle: org.apache.spark.shuffle.celeborn.CelebornShuffleHandle[K, _, C], startPartition: Int, endPartition: Int, startMapIndex: Int, endMapIndex: Int, context: org.apache.spark.TaskContext, conf: org.apache.celeborn.common.CelebornConf, metrics: org.apache.spark.shuffle.ShuffleReadMetricsReporter, shuffleIdTracker: org.apache.spark.shuffle.celeborn.ExecutorShuffleIdTracker)org.apache.spark.shuffle.celeborn.CelebornShuffleReader[K,C]

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

#1144

fixed in this pr, also added GA

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Extracting celeborn/uniffle/paimon code to seperated modules

4 participants