GitHub user mynameborat opened a pull request:
https://github.com/apache/samza/pull/895
Separate thread pool sharing between tasks and runloop
Currently, AsyncStreamTaskAdapter and AsyncRunLoop share thread pools and
the thread pool size is governed by `job.container.thread.pool.size`. This
introduces disparity in the semantics of `task.max.concurrency` between async
stream task vs adapted async stream task.
In this PR, we separate the thread pools used by the adapter and the
runloop to bring parity between variants of async stream tasks.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mynameborat/samza separate-task-thread-pool
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/895.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 #895
----
commit 19e3edd0cb31c4d28d6d9ddc6923d4e4a4372e88
Author: mynameborat <bharath.kumarasubramanian@...>
Date: 2019-01-24T23:21:24Z
Separate thread pool sharing between tasks and runloop
----
---
