GitHub user navina opened a pull request:
https://github.com/apache/samza/pull/148
SAMZA-1212 - Refactor interaction between StreamProcessor, JobCoordinator
and SamzaContainer
See SAMZA-1212 for motivation toward this refactoring.
Changes here are:
* Removed awaitStart (blocking) method in StreamProcessor, JobCoordinator
and SamzaContainer
* Introduced SamzaContainerListener and JobCoordinatorListener interface
implemented by StreamProcessor
* Introduced SamzaContainerStatus to handler failures and lifecycle using
Listener interfaces
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/navina/samza SAMZA-1212
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/148.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #148
----
commit d81cfdca4b84f02b86ab70657c8c4636e8902b9a
Author: Navina Ramesh <[email protected]>
Date: 2017-04-14T00:20:38Z
Remove containerId from SamzaContainer.apply
commit c4a10242b6e85345ed4515b98ec407435c1fdce1
Author: Navina Ramesh <[email protected]>
Date: 2017-04-14T00:22:01Z
Removing onBecomingLeader for readability
commit 56028361552b37a27991c6cac1f3e00cc3d3a0f2
Author: Navina Ramesh <[email protected]>
Date: 2017-04-14T00:26:01Z
Removing awaitStart
commit fd99fd65fb437afed04240b3971b3cefc1f52f1d
Author: Navina Ramesh <[email protected]>
Date: 2017-04-14T19:12:46Z
Added JobCoordinator Listener. Trying to remove Samzacontainer controller
commit e77aa502df74cedb87c50a8e039135975504381e
Author: Navina Ramesh <[email protected]>
Date: 2017-04-25T01:36:14Z
Adding ProcessorErrorHandler, SamzaContainerStatus, JobCoordinatorListener,
SamzaContainerListener
commit 3cbf259c1e9fea7a4d24af93a812e75d9947aac8
Author: Navina Ramesh <[email protected]>
Date: 2017-04-26T23:01:24Z
Documenting state transitions for SamzaContainer
commit 679b2f54aa7a39c8dae688f9b446aa9bad9d267f
Author: Navina Ramesh <[email protected]>
Date: 2017-04-26T23:03:00Z
adding some log lines in LocalContainerRunner
commit 3b65cc983d7d734d6fdf2a81cb155fbad0e774b3
Author: Navina Ramesh <[email protected]>
Date: 2017-04-27T01:36:25Z
Fixed integration test failures by throwing the exception in the listener
for ThreadJob
commit b1b61f58b2e06a1e7f5fc602fe9007d4c1a003a0
Author: Navina Ramesh <[email protected]>
Date: 2017-04-27T19:42:54Z
Added a few tests in TestSamzaContainer
commit a2db96924ebd479e2110fc611c86c3c310336212
Author: Navina Ramesh <[email protected]>
Date: 2017-04-27T23:38:29Z
Added test for sp.stop()
commit bc74cd5670aacfe5c4eae7968973e68f9f700876
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T00:23:32Z
Adding setContainerListener explicitly in SamzaContainer
commit 07adf3c6ce39a893a0995498bc012cf6c14c43be
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T02:38:24Z
Added documentation in JobCoordinator interface
commit 78a73540cc0cd84db286737b190c596dcde93d1f
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T02:43:00Z
Removed ProcessorErrorHandler
commit 5d1b28c6b566ca691a955d94bb1daf29a96737ef
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T02:45:47Z
Removing commetned out code
commit 42ffc7d6c1d5e657b35d9482df30f0e201bdbb27
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T05:00:40Z
Adding docs to JobCoordinatorListener
commit 5ff163cf19c85875a0e2a8d85682487186ffc6c5
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T05:36:02Z
Added javadocs for SamzaContainerListener
commit f3551656037a058aebd62e9f7dacaafeb49d2f94
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T06:33:49Z
Cleaning up StreamProcessor code and jobCoordinator docs
commit c624d75afd77dd028a4406d6e07d2ef801098b03
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T07:09:36Z
Fixing standaloneJobCoordinator
commit c116a3c55149a4cca738a66ec925569385568be9
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T07:14:04Z
Adding null checks on processorListener
commit 6f0715c4944255409bd78fd178c8e9976e60f485
Author: Navina Ramesh <[email protected]>
Date: 2017-04-28T07:32:37Z
Fixing ZkJobCoordinator
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
