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

Posted to dev@samza.apache.org by navina <gi...@git.apache.org> on 2017/05/05 08:32:45 UTC

[GitHub] samza pull request #166: SAMZA-1150 : Handling Error propagation between ZkJ...

GitHub user navina opened a pull request:

    https://github.com/apache/samza/pull/166

    SAMZA-1150 : Handling Error propagation between ZkJobCoordinator & DebounceTimer

    * Treats all errors in jobcoordinator as FATAL and shuts-down the streamprocessor
    * [Bug] Fixed bug reported in SAMZA-1241
    * Introduced a callback to be associated with the timer (same callback for every Runnable failure)
    
    **TBD**: some more unit tests

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/navina/samza SAMZA-1150

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/samza/pull/166.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 #166
    
----
commit 8996cb56190bdf5da21f9d767b7db7ee062fc1e8
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-14T00:20:38Z

    Remove containerId from SamzaContainer.apply

commit 6931cc62a3e0908fc1dee48055a0d9f95072746e
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-14T00:22:01Z

    Removing onBecomingLeader for readability

commit 528086dba116d3a9b2772d493e9430784236c5ca
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-14T00:26:01Z

    Removing awaitStart

commit eb16378fb0b127563a3f0a92ca1b1249813d60c8
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-14T19:12:46Z

    Added JobCoordinator Listener. Trying to remove Samzacontainer controller

commit 4d21ee56fafc00daa4c70e2ff275e66f34f3c1a4
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-25T01:36:14Z

    Adding ProcessorErrorHandler, SamzaContainerStatus, JobCoordinatorListener, SamzaContainerListener

commit 38e3f40d2c464dc5b570b175e670060881f554d9
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-26T23:01:24Z

    Documenting state transitions for SamzaContainer

commit bfe1f17d16cc52c809b084328287c93d39452dfa
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-26T23:03:00Z

    adding some log lines in LocalContainerRunner

commit 376f6ac2eb21977cd7a958198efe33da75c8afa9
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-27T01:36:25Z

    Fixed integration test failures by throwing the exception in the listener for ThreadJob

commit 38271d69d72a731914c36f502f49be7c7d0ec235
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-27T19:42:54Z

    Added a few tests in TestSamzaContainer

commit 2df4666319676e56600c523712c54ee6f842fae4
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-27T23:38:29Z

    Added test for sp.stop()

commit 6f6255e3f34d0aa9f437f0589bf02d0f3451e089
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T00:23:32Z

    Adding setContainerListener explicitly in SamzaContainer

commit 53bb48c453d1e48f978a457d43addc5f32fce3ef
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T02:38:24Z

    Added documentation in JobCoordinator interface

commit 012eeff7d347d5e273d3938f62dedf59b849ea86
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T02:43:00Z

    Removed ProcessorErrorHandler

commit 48cf739fc2f585bb7a21161a66270bb992419f5d
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T02:45:47Z

    Removing commetned out code

commit 6bf290545eb3485c8530995219e42cc134fed10f
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T05:00:40Z

    Adding docs to JobCoordinatorListener

commit db96e5d0dcef3f44d0e986938089c88c1ddebdd7
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T05:36:02Z

    Added javadocs for SamzaContainerListener

commit ca27a8795b85d539122a8fb19fd8fbdc8297634b
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T06:33:49Z

    Cleaning up StreamProcessor code and jobCoordinator docs

commit 442035912f2e60484692570d56be33bf5eb459a3
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T07:09:36Z

    Fixing standaloneJobCoordinator

commit 525ac15cf2e141970fe921214ed3f71cd7dadc37
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T07:14:04Z

    Adding null checks on processorListener

commit 23a6f762b462a8aaf81126c9060587c0de042269
Author: Navina Ramesh <na...@apache.org>
Date:   2017-04-28T07:32:37Z

    Fixing ZkJobCoordinator

commit 22e5ddd5f0217b8254b0def2fc2a2a7f94bfe7ee
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-02T22:19:46Z

    Removing unused variable in ZkJobCoordinator

commit 4a5800512271b3be7236898373f51b89935014fe
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-02T22:38:15Z

    Adding javadoc to sp.stop and removing incorrect comment in ZkControllerImpl

commit 6c580d3fdbcd8f02ecff08d296eda1128865e4de
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-02T23:32:29Z

    Fixing LocalContainerRunner

commit 3a5d1811b4de9a229f5ea4b68cc61b81b69908e6
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-03T00:06:58Z

    Minor changes to codestyle and docs

commit ee29c0f75f409a11b40ceaa313cfea772772f864
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-03T02:23:16Z

    Adding IllegalContainerStateException

commit d58d789409d302a4ca024ed2d3455a440dfb61c9
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-03T05:32:47Z

    Moving pkg private methods after public methods in StreamProcessor

commit edfad1eee572febe5a2b66946c0cfdea19c8f354
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-03T05:58:58Z

    Fixing comments based on Prateek's suggestions

commit 3d59fc66d4b17b09e2dc7e2d2ef10c1a5e8db991
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-03T06:39:10Z

    Changing RUNNING to STARTED

commit f58caeed4ef2d6c1a40c7a5a9d5fcc1463bc622a
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-03T07:03:30Z

    Changing documentation formatting

commit 51db4416f08c69c7c917bce4cf3fcb86579556d4
Author: Navina Ramesh <na...@apache.org>
Date:   2017-05-03T19:00:18Z

    Handling IllegalContainerStateException in StreamProcessor.stop

----


---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] samza pull request #166: SAMZA-1150 : Handling Error propagation between ZkJ...

Posted by asfgit <gi...@git.apache.org>.

Github user asfgit closed the pull request at:

    https://github.com/apache/samza/pull/166


---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---