Skip to content

[Spark] Make MERGE source materialize depend on checkpointRDDBlockIdNotFoundError error class, not message - #5291

Merged
zachschuermann merged 5 commits into
delta-io:masterfrom
xupefei:rdd-lost-detection
Oct 6, 2025
Merged

zachschuermann merged 5 commits into
delta-io:masterfrom
xupefei:rdd-lost-detection

Conversation

@xupefei

@xupefei xupefei commented Oct 3, 2025 •

Copy link
Copy Markdown
Collaborator

Which Delta project/connector is this regarding?

  • Spark
  • Standalone
  • Flink
  • Kernel
  • Other (fill in here)

Description

This PR improves #3649 by providing version-specific checks for SparkException.

How was this patch tested?

Update an existing test.

Does this PR introduce any user-facing changes?

No.

@xupefei xupefei changed the title . [Spark] Make MERGE source materialize depend on checkpointRDDBlockIdNotFoundError error class, not message Oct 3, 2025
# Conflicts:
#	spark/src/main/scala/org/apache/spark/sql/delta/commands/merge/MergeIntoMaterializeSource.scala
@xupefei

xupefei commented Oct 6, 2025

Copy link
Copy Markdown
Collaborator Author

Hey @juliuszsompolski, I saw you have a similar PR #3649. Can you review this one? Thank you!

@juliuszsompolski juliuszsompolski left a comment

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

LGTM! Thank you. I had my PR blocked on Spark 4.0 for quite a while, but it's actually quite clean to solve with the shim!

@zachschuermann
zachschuermann merged commit 6236fdf into delta-io:master Oct 6, 2025
27 checks passed
@xupefei
xupefei deleted the rdd-lost-detection branch October 7, 2025 08:00
huashi-st pushed a commit to huashi-st/delta that referenced this pull request Apr 24, 2026
…otFoundError error class, not message (delta-io#5291)

#### Which Delta project/connector is this regarding?

- [x] Spark
- [ ] Standalone
- [ ] Flink
- [ ] Kernel
- [ ] Other (fill in here)

## Description

This PR improves delta-io#3649 by
providing version-specific checks for SparkException.

## How was this patch tested?

Update an existing test.

## Does this PR introduce _any_ user-facing changes?

No.
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.

3 participants