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

Posted to commits@samza.apache.org by bh...@apache.org on 2023/06/13 23:57:22 UTC

[samza] branch master updated (4600dd3dd -> 9111bb744)

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(-)