Details
-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: v0.9.4
-
Component/s: None
-
Labels:None
Description
The getUnackedSource call in NaiveFileWALManager blocks if there are no elements to process in queue. If interrupted and the logged and sent queues are empty, this should exit cleanly. If both logged and sent queues are empty we can definitely exit with without error.
If the logged queue still contains data, and this is interrupted, it should definitely fail.
It is debatable if we should exit cleanly if the logged queue is empty and the sent queue is not (sent but not acked). This patch exits cleanly only if the ack has been received as well.
Attachments
Issue Links
- blocks
-
FLUME-592 Fix intermittent / flaky tests for v0.9.4
-
- Resolved
-