GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4645
[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:
https://github.com/apache/flink/pull/4645.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 #4645
----
commit bf910ff69fa2754c235f8f0d957cadefbc37c53f
Author: zentol <[email protected]>
Date: 2017-09-05T10:58:57Z
[FLINK-7582] [REST] Netty thread immediately parses responses
----
---
