[
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]
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
>
> 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]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
