-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31392/
-----------------------------------------------------------
Review request for samza.
Bugs: SAMZA-555
https://issues.apache.org/jira/browse/SAMZA-555
Repository: samza
Description
-------
fix comments
add notes
clear assignments after coordinator is elected.
add logging
make job runner block until job finishes
add standalone job and standalone job factory. make zk work with hierarchical
chroot paths.
add unsubscribe to coordinator controller
unsubscribe to assignment changes in container listener
both tests pass.
fix bug in container controller to announce ownership
add initial container controller
make test do asserts
standalone main method works as expected.
rework assignTasksToContainers. controller isn't watching /containers
sequential ids yet, but it should.
fiddling around with CLI test
writing a little main method to play with zk and coordinator
initial coordinator draft
add missing leadership check
working on zk coordinator controller.
messing around
sketch out a hacky controller.
adding core dependency
create samza-standalone project
Diffs
-----
build.gradle b803276c13280ffed5ca1ce8ea608d81010e9b6b
gradle/dependency-versions.gradle 84be50b216e7dc3c430e0979a933d846f8ebbb8d
samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala
3b6685e00837a4aaf809813e62b7e52823bc07a9
samza-core/src/main/scala/org/apache/samza/container/RunLoop.scala
499f5c6a58ff88ef9105b7b6ca168215fb82f35c
samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala
16345cd1c1354a0d25a0000d81a307dbe3abbe81
samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventStringSerde.java
f9a0960735705f49f46f2e5b373ba4d33aadcb47
samza-standalone/src/main/java/org/apache/samza/job/standalone/StandaloneJob.java
PRE-CREATION
samza-standalone/src/main/java/org/apache/samza/job/standalone/StandaloneJobFactory.java
PRE-CREATION
samza-standalone/src/main/java/org/apache/samza/job/standalone/controller/StandaloneZkContainerController.java
PRE-CREATION
samza-standalone/src/main/java/org/apache/samza/job/standalone/controller/StandaloneZkCoordinatorController.java
PRE-CREATION
samza-standalone/src/main/java/org/apache/samza/job/standalone/controller/StandaloneZkCoordinatorState.java
PRE-CREATION
samza-standalone/src/main/java/org/apache/samza/serializers/zk/ZkJsonSerde.java
PRE-CREATION
samza-standalone/src/main/java/org/apache/samza/util/ZkUtil.java PRE-CREATION
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemConsumer.java
a282dbb2976cb916d41649c3fbe070008c6621ee
samza-test/src/main/java/org/apache/samza/task/MockTask.java PRE-CREATION
samza-test/src/test/java/org/apache/samza/job/standalone/controller/TestStandaloneZkCoordinatorController.java
PRE-CREATION
settings.gradle bb07a3b84b14dcef94da1bb166eab6aa3d0026bb
Diff: https://reviews.apache.org/r/31392/diff/
Testing
-------
Thanks,
Chris Riccomini
