Skip to content

[rust] Fix lost wakeup in LogFetchBuffer::await_not_empty#3712

Merged
fresh-borzoni merged 1 commit into
apache:mainfrom
fresh-borzoni:rust-await-not-empty-lost-wakeup
Jul 22, 2026
Merged

[rust] Fix lost wakeup in LogFetchBuffer::await_not_empty#3712
fresh-borzoni merged 1 commit into
apache:mainfrom
fresh-borzoni:rust-await-not-empty-lost-wakeup

Conversation

@fresh-borzoni

@fresh-borzoni fresh-borzoni commented Jul 21, 2026

Copy link
Copy Markdown
Member

closes #3713

Arm the waiter with enable() before the emptiness check so a notify_waiters() racing the check isn't lost.
Root cause behind #3694's flaky poll.

Also drops the unused DEFAULT_POLL_INTERVAL.

@fresh-borzoni

Copy link
Copy Markdown
Member Author

@charlesdong1991 @LiebingYu PTAL 🙏

@charlesdong1991 charlesdong1991 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.

lgtm

Comment thread fluss-rust/crates/fluss/src/client/table/log_fetch_buffer.rs
@fresh-borzoni
fresh-borzoni merged commit 6267ec8 into apache:main Jul 22, 2026
13 checks passed
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.

[rust] Lost wakeup in LogFetchBuffer::await_not_empty causes empty poll

2 participants