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

Posted to commits@samza.apache.org by sh...@apache.org on 2019/10/24 20:51:52 UTC

[samza] branch master updated (2671231 -> f72577d)

This is an automated email from the ASF dual-hosted git repository.

shanthoosh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.


    from 2671231  Include the ScalarUDF implementations with the configured package prefix in ReflectionBasedUdfResolver. (#1202)
     add f72577d  SAMZA-2334: SSPGrouperProxy should check if job is stateful, not if host-affinity is enabled (#1179)

No new revisions were added by this update.

Summary of changes:
 .../versioned/jobs/samza-configurations.md         |   3 +-
 .../java/org/apache/samza/config/JobConfig.java    |   7 +
 .../container/grouper/stream/SSPGrouperProxy.java  |  99 ++++--
 .../apache/samza/coordinator/JobModelManager.scala |  12 +-
 .../grouper/stream/TestGroupByPartition.java       | 221 +-----------
 .../TestGroupByPartitionWithGrouperProxy.java      | 366 ++++++++++++++++++++
 .../stream/TestGroupBySystemStreamPartition.java   | 229 +------------
 ...oupBySystemStreamPartitionWithGrouperProxy.java | 369 +++++++++++++++++++++
 .../processor/TestZkLocalApplicationRunner.java    |  76 +++--
 9 files changed, 883 insertions(+), 499 deletions(-)
 create mode 100644 samza-core/src/test/java/org/apache/samza/container/grouper/stream/TestGroupByPartitionWithGrouperProxy.java
 create mode 100644 samza-core/src/test/java/org/apache/samza/container/grouper/stream/TestGroupBySystemStreamPartitionWithGrouperProxy.java