Skip to content

feat(inkless:consolidation): serve consolidated reads from remote via OFFSET_MOVED_TO_TIERED_STORAGE#650

Open
viktorsomogyi wants to merge 1 commit into
mainfrom
svv/ts-unification-remote-read
Open

feat(inkless:consolidation): serve consolidated reads from remote via OFFSET_MOVED_TO_TIERED_STORAGE#650
viktorsomogyi wants to merge 1 commit into
mainfrom
svv/ts-unification-remote-read

Conversation

@viktorsomogyi

Copy link
Copy Markdown
Contributor

When a consolidation fetch targets an offset that sits below the diskless WAL start but at/above the whole-log start, that data was consolidated to the remote tier and can only be served from there. DisklessLeaderEndPoint now signals OFFSET_MOVED_TO_TIERED_STORAGE for that range so the stock tier-state machine rebuilds the leader-epoch cache and producer snapshot from remote before resuming the WAL fetch.

This is the core read-from-remote path for consolidated topics after the diskless WAL is pruned or the local log is lost.

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

Copilot encountered an error and was unable to review this pull request. You can try again by re-requesting a review.

@viktorsomogyi viktorsomogyi force-pushed the svv/ts-unification-remote-read branch 2 times, most recently from 15b5030 to e40c1b5 Compare June 16, 2026 15:24
@viktorsomogyi viktorsomogyi changed the base branch from svv/ts-unification-systest-test1 to main June 16, 2026 15:24
@viktorsomogyi viktorsomogyi requested a review from Copilot June 16, 2026 15:24

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

Pull request overview

Copilot reviewed 2 out of 2 changed files in this pull request and generated 2 comments.

Comment thread core/src/main/scala/io/aiven/inkless/consolidation/DisklessLeaderEndPoint.scala Outdated
@viktorsomogyi viktorsomogyi force-pushed the svv/ts-unification-remote-read branch from e40c1b5 to 14a41c1 Compare June 16, 2026 17:41
… OFFSET_MOVED_TO_TIERED_STORAGE

When a consolidation fetch targets an offset that sits below the diskless WAL
start but at/above the whole-log start, that data was consolidated to the
remote tier and can only be served from there. DisklessLeaderEndPoint now
signals OFFSET_MOVED_TO_TIERED_STORAGE for that range so the stock tier-state
machine rebuilds the leader-epoch cache and producer snapshot from remote
before resuming the WAL fetch.

This is the core read-from-remote path for consolidated topics after the
diskless WAL is pruned or the local log is lost.

Co-authored-by: Cursor <cursoragent@cursor.com>

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

Pull request overview

Copilot reviewed 2 out of 2 changed files in this pull request and generated no new comments.

@viktorsomogyi viktorsomogyi marked this pull request as ready for review June 16, 2026 18:04
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.

2 participants