-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.8.0
-
Fix Version/s: 1.9.0
-
Component/s: None
-
Labels:None
TaildirSource.process() always returns Status.READY and sleeps inside the method.
It should return Status.READY / Status.BACKOFF and this status would control the common backoff sleeping mechanism implemented in PollableSourceRunner.PollingRunner.
This is an old issue, but due to the changes implemented in FLUME-3101, it can lead to unnecessary waiting cycles. So it must be fixed now.
- is related to
-
FLUME-3101 taildir source may endless loop when tail a file
-
- Resolved
-
- links to