Skip to content

Conversation

@swuferhong
Copy link
Contributor

@swuferhong swuferhong commented Dec 8, 2025

Purpose

Linked issue: close #2110

Add another queue for re-enqueue operation only in LookupSender to avoid deadlocks during re-enqueue

Brief change log

Tests

API and Format

Documentation

@swuferhong swuferhong force-pushed the fix-lookup-dead-block branch 6 times, most recently from 14260b7 to 32347d2 Compare December 8, 2025 09:48
@swuferhong swuferhong changed the title [client] Change the implementation of LookupQueue from ArrayBlockingQueue to an unbounded LinkedBlockingDeque to avoid deadlocks during re-enqueue [client] Add another queue for re-enqueue operation only in LookupSender to avoid deadlocks during re-enqueue Dec 8, 2025
@swuferhong swuferhong force-pushed the fix-lookup-dead-block branch from 32347d2 to 240b400 Compare December 8, 2025 10:17
@wuchong wuchong merged commit f11b43b into apache:main Dec 11, 2025
5 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.

Flink lookup will Intermittent timeout when Fluss cluster upgrading

2 participants