You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Chris Zhang (Jira)" <ji...@apache.org> on 2022/03/08 02:27:00 UTC

[jira] [Updated] (SAMZA-2720) Allow custom task executor to be injected and used

     [ https://issues.apache.org/jira/browse/SAMZA-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chris Zhang updated SAMZA-2720:
-------------------------------
    Description: 
Currently when running tasks in multi thread mode, plain java executor is used. We should open this up to allow any executor to be used. Users may wish to inject their own customized executor to run the tasks.

Code link to executor: [link|https://github.com/apache/samza/blob/master/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala#L459]


Design doc: [link|https://docs.google.com/document/d/1XJmwsjNPz9KtCjVb0w1HngwBRXzOgjQ_yrBItiyRknE/edit?usp=sharing]

PR: [link|https://github.com/apache/samza/pull/1588]

  was:
Currently when running tasks in multi thread mode, plain java executor is used. We should open this up to allow any executor to be used. Users may wish to inject their own customized executor to run the tasks.

Code link to executor: [link|https://github.com/apache/samza/blob/master/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala#L459]


Design doc: [link|https://docs.google.com/document/d/1XJmwsjNPz9KtCjVb0w1HngwBRXzOgjQ_yrBItiyRknE/edit?usp=sharing]


> Allow custom task executor to be injected and used
> --------------------------------------------------
>
>                 Key: SAMZA-2720
>                 URL: https://issues.apache.org/jira/browse/SAMZA-2720
>             Project: Samza
>          Issue Type: Improvement
>            Reporter: Chris Zhang
>            Priority: Major
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> Currently when running tasks in multi thread mode, plain java executor is used. We should open this up to allow any executor to be used. Users may wish to inject their own customized executor to run the tasks.
> Code link to executor: [link|https://github.com/apache/samza/blob/master/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala#L459]
> Design doc: [link|https://docs.google.com/document/d/1XJmwsjNPz9KtCjVb0w1HngwBRXzOgjQ_yrBItiyRknE/edit?usp=sharing]
> PR: [link|https://github.com/apache/samza/pull/1588]



--
This message was sent by Atlassian Jira
(v8.20.1#820001)