Skip to content

[FLINK-40555][runtime] Isolate unreadable JobResultStore entries per job - #12

Closed
XComp wants to merge 1 commit into
FLINK-40554from
FLINK-40555
Closed

[FLINK-40555][runtime] Isolate unreadable JobResultStore entries per job#12
XComp wants to merge 1 commit into
FLINK-40554from
FLINK-40555

Conversation

@XComp

@XCompXComp commented Sep 4, 2026

Copy link
Copy Markdown
Owner

A corrupted JobResultStore file would have lead to a JobManager failover. The new implementation utilizes the new configuration parameter introduced with FLINK-40554 to skips parsing the entry and quarantines the file under a different name for manual investigation and cleanup.

What is the purpose of the change

  • Extends functionality from FLINK-40554 to cover also corrupted JRS entry files.

Brief change log

  • Adds error log handling for corrupted files which will be renamed

Verifying this change

  • Unit tests added

Does this pull request potentially affect one of the following parts:

  • Dependencies (does it add or upgrade a dependency): no
  • The public API, i.e., is any changed class annotated with @Public(Evolving): no
  • The serializers: no
  • The runtime per-record code paths (performance sensitive): no
  • Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: yes
  • The S3 file system connector: no

Documentation

  • Does this pull request introduce a new feature? yes
  • If yes, how is the feature documented? docs

A corrupted JobResultStore file would have lead to a JobManager failover. The new implementation utilizes the new configuration parameter introduced with FLINK-40554 to skips parsing the entry and quarantines the file under a different name for manual investigation and cleanup.
@XComp

XComp commented Sep 7, 2026

Copy link
Copy Markdown
OwnerAuthor

See FLINK-40554 PR comment for closing remark.

@XCompXComp closed this Sep 7, 2026
Sign up for freeto 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.

1 participant

@XComp