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

Posted to dev@samza.apache.org by mynameborat <gi...@git.apache.org> on 2019/01/24 23:42:10 UTC

[GitHub] samza pull request #895: Separate thread pool sharing between tasks and runl...

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 <bh...@...>
Date:   2019-01-24T23:21:24Z

    Separate thread pool sharing between tasks and runloop

----


---