GitHub user turcsanyip opened a pull request:
https://github.com/apache/flume/pull/241
FLUME-3294 Fix polling logic in TaildirSource
TaildirSource.process() implements the correct polling logic now. It returns
Status.READY / Status.BACKOFF which controls the common backoff sleeping
mechanism implemented in PollableSourceRunner.PollingRunner (instead of
always returning Status.READY and sleeping inside the method which was
an incorrect behaviour).
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/turcsanyip/flume FLUME-3294
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flume/pull/241.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #241
----
commit adf44790848b371fcf39aa8a8917a7d9cd5bb66e
Author: turcsanyi <turcsanyi@...>
Date: 2018-11-22T12:43:39Z
FLUME-3294 Fix polling logic in TaildirSource
TaildirSource.process() implements the correct polling logic now. It returns
Status.READY / Status.BACKOFF which controls the common backoff sleeping
mechanism implemented in PollableSourceRunner.PollingRunner (instead of
always returning Status.READY and sleeping inside the method which was
an incorrect behaviour).
----
---
