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/02/07 02:36:29 UTC

[samza] branch master updated (88ce78f -> 9f32b52)

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 88ce78f  SAMZA-2098: Samza sql shell: Fix the LOG typo
     new 8b2f340  SAMZA-2083: Adding the register(SSP, startpoint) API to the SystemConsumer.
     new 8e277b0  Address review comments.
     new 02b98dc  Address review comments.
     new 9f32b52  Merge pull request #908 from shanthoosh/system_consumer_register

The 1570 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../org/apache/samza/system/SystemConsumer.java    | 39 +++++++++++------
 .../scala/org/apache/samza/config/JobConfig.scala  |  2 +-
 .../org/apache/samza/system/SystemConsumers.scala  | 18 ++++----
 .../samza/storage/TestTaskStorageManager.scala     |  2 +-
 .../apache/samza/system/TestSystemConsumers.scala  | 50 +++-------------------
 5 files changed, 43 insertions(+), 68 deletions(-)