Skip to content

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

Merged
giuseppelillo merged 1 commit into
mainfrom
svv/ts-unification-remote-read
Jun 22, 2026
Merged

feat(inkless:consolidation): serve consolidated reads from remote via OFFSET_MOVED_TO_TIERED_STORAGE#650
giuseppelillo merged 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 2 times, most recently from 14a41c1 to 108581e Compare June 16, 2026 17:47
@viktorsomogyi
viktorsomogyi requested a review from Copilot June 16, 2026 17:48

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
@viktorsomogyi
viktorsomogyi force-pushed the svv/ts-unification-remote-read branch from 108581e to cff8f1d Compare June 22, 2026 10:05
… 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>
@viktorsomogyi
viktorsomogyi force-pushed the svv/ts-unification-remote-read branch from cff8f1d to 51a1ede Compare June 22, 2026 10:58
@giuseppelillo
giuseppelillo merged commit b8ceb7f into main Jun 22, 2026
3 checks passed
@giuseppelillo
giuseppelillo deleted the svv/ts-unification-remote-read branch June 22, 2026 13:46
giuseppelillo pushed a commit that referenced this pull request Jun 23, 2026
… OFFSET_MOVED_TO_TIERED_STORAGE (#650)

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>
giuseppelillo pushed a commit that referenced this pull request Jun 23, 2026
… OFFSET_MOVED_TO_TIERED_STORAGE (#650)

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