You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by turcsanyip <gi...@git.apache.org> on 2018/11/22 17:43:08 UTC

[GitHub] flume pull request #241: FLUME-3294 Fix polling logic in TaildirSource

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 <tu...@...>
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).

----


---

[GitHub] flume pull request #241: FLUME-3294 Fix polling logic in TaildirSource

Posted by asfgit <gi...@git.apache.org>.

Github user asfgit closed the pull request at:

    https://github.com/apache/flume/pull/241


---