This is an automated email from the ASF dual-hosted git repository.
pmaheshwari pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from 664ebb0 SAMZA-2721: Container should exit with non-zero status code
in case of errors during launch (#1583)
new e0bd1f1 SAMZA-2689 [Elasticity] generate JobModel and update RunLoop
with (elastic) tasks processing keyBuckets of SystemStreamPartition
new 69b9beb merge master and fix merge conflicts
new 8e85333 SAMZA-2689 [Elasticity] generate JobModel and update RunLoop
with (elastic) tasks processing keyBuckets of SystemStreamPartition
new 5b733a4 add tests and address comments
new d134bef merge
new 0c2f9a1 use envelop.getSSP(elasticityFactor) uniformly
new 55a8b26 remove new test in TestRunLoop as it needs special handling
for end_of_stream offsets
new ae4453b handle end of stream/watermark, add runloop test
new 589f5c5 pick only one elastic task to broadcast control messages like
eos and watermark
new a7c77c6 address comments
new bee7f25 Merge pull request #1580 from
lakshmi-manasa-g/elasticity-ssp-grouper
The 2455 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:
.../samza/system/IncomingMessageEnvelope.java | 22 ++-
.../java/org/apache/samza/config/JobConfig.java | 6 +-
.../java/org/apache/samza/container/RunLoop.java | 83 ++++++++++-
.../org/apache/samza/container/RunLoopFactory.java | 8 +-
.../container/grouper/stream/GroupByPartition.java | 22 ++-
.../stream/GroupBySystemStreamPartition.java | 18 ++-
.../apache/samza/operators/impl/OperatorImpl.java | 34 ++++-
.../apache/samza/container/SamzaContainer.scala | 6 +-
.../org/apache/samza/container/TaskInstance.scala | 13 +-
.../org/apache/samza/system/SystemConsumers.scala | 22 ++-
.../org/apache/samza/config/TestJobConfig.java | 32 +++-
.../org/apache/samza/container/TestRunLoop.java | 32 ++++
.../grouper/stream/TestGroupByPartition.java | 17 +++
.../stream/TestGroupBySystemStreamPartition.java | 22 +++
.../serializers/model/TestSamzaObjectMapper.java | 162 +++++++++++++++++++++
.../apache/samza/container/TestTaskInstance.scala | 48 +++++-
.../operator/TestRepartitionJoinWindowApp.java | 2 +-
17 files changed, 509 insertions(+), 40 deletions(-)
