flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zentol <...@git.apache.org>
Subject [GitHub] flink pull request #4645: [FLINK-7582] [REST] Netty thread immediately parse...
Date Tue, 05 Sep 2017 11:01:57 GMT
GitHub user zentol opened a pull request:


    [FLINK-7582] [REST] Netty thread immediately parses responses

    ## What is the purpose of the change
    This PR modifies the RestClient to make the netty receiver threads parse responses (and
complete the associated future) immediately after receiving a response, instead of deferring
the parsing to a separate executor.
    This guarantees that we don't buffer responses that haven't been parsed yet. This was
previously the case if the executor could not keep up with the response rate, for example
because it was used exclusively for sending requests.
    ## Verifying this change
    This change is a trivial rework / code cleanup without any test coverage.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/zentol/flink 7582

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #4645
commit bf910ff69fa2754c235f8f0d957cadefbc37c53f
Author: zentol <chesnay@apache.org>
Date:   2017-09-05T10:58:57Z

    [FLINK-7582] [REST] Netty thread immediately parses responses



View raw message