This is an automated email from the ASF dual-hosted git repository. bharathkk pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/samza.git
from 4600dd3dd SAMZA-2782: Clean up container thread pool DI into StreamOperatorTask (#1668) add 9111bb744 SAMZA-2781: Use framework thread to execute hand-offs and sub-DAG execution (#1667) No new revisions were added by this update. Summary of changes: .../java/org/apache/samza/context/TaskContext.java | 9 ++ .../org/apache/samza/task/TaskExecutorFactory.java | 22 ++++ .../org/apache/samza/context/TaskContextImpl.java | 12 ++- .../apache/samza/operators/impl/OperatorImpl.java | 40 +++---- .../samza/task/DefaultTaskExecutorFactory.java | 40 +++++++ .../org/apache/samza/container/TaskInstance.scala | 14 ++- .../apache/samza/context/TestTaskContextImpl.java | 4 +- .../apache/samza/operators/TestJoinOperator.java | 59 +++++------ .../samza/operators/impl/TestOperatorImpl.java | 5 +- .../operators/impl/TestOperatorImplGraph.java | 2 + .../samza/operators/impl/TestWindowOperator.java | 115 +++++++++++---------- .../samza/task/TestDefaultTaskExecutorFactory.java | 39 ++++++- .../apache/samza/testUtils/StreamTestUtils.java | 25 +++++ .../samza/sql/system/TestAvroSystemFactory.java | 2 +- .../samza/test/samzasql/TestSamzaSqlEndToEnd.java | 2 +- 15 files changed, 272 insertions(+), 118 deletions(-)