Skip to content

[server] complete delay fetch after produce#3412

Open
gyang94 wants to merge 1 commit into
apache:mainfrom
gyang94:complete-delay-fetch
Open

[server] complete delay fetch after produce#3412
gyang94 wants to merge 1 commit into
apache:mainfrom
gyang94:complete-delay-fetch

Conversation

@gyang94

@gyang94 gyang94 commented Jun 1, 2026

Copy link
Copy Markdown
Contributor

Purpose

Linked issue: close #3455

Brief change log

Introduce an ActionQueue mechanism that decouples the enqueuing of delayed fetch completions from their execution:

  1. New ActionQueue interface + DelayedActionQueue implementation — an action queue based on ConcurrentLinkedQueue
  2. Enqueue actions after produce — after appendRecordsToLog completes, enqueue checkAndComplete actions for each successfully written bucket into the action queue
  3. Framework-level trigger — in FlussRequestHandler's finally block, call service.tryCompleteActions() to ensure pending delayed operations are completed after every RPC request finishes

Tests

API and Format

Documentation

@gyang94 gyang94 force-pushed the complete-delay-fetch branch from 7a4cf2e to f789177 Compare June 8, 2026 04:19
@gyang94 gyang94 changed the title [WIP]complete delay fetch [server] complete delay fetch Jun 8, 2026
@gyang94 gyang94 changed the title [server] complete delay fetch [server] complete delay fetch after produce Jun 8, 2026
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.

[server] complete delayed fetch operations after produce to reduce fetch latency

1 participant