[jira] [Commented] (SAMZA-1132) LocalApplicationRunner for local exeuction of Samza StreamApplication

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/SAMZA-1132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960109#comment-15960109 ] 

ASF GitHub Bot commented on SAMZA-1132:
---------------------------------------

GitHub user xinyuiscool opened a pull request:

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

    SAMZA-1132: LocalApplicationRunner for StreamApplication

    LocalApplicationRunner runs the StreamApplication locally on every node that the application is deployed to. LocalRunner.start() is blocking until the process is killed or user invoke LocalRunner.stop() from another thread. It can be configured to use Zk for coordination.

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

    $ git pull https://github.com/xinyuiscool/samza SAMZA-1132

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

    https://github.com/apache/samza/pull/117.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 #117
    
----
commit 2fcd6a143eeecfea1ca79f3bee6c2b29bb2adef1
Author: Xinyu Liu <xi...@xiliu-ld.linkedin.biz>
Date:   2017-04-07T00:52:46Z

    SAMZA-1132: LocalApplicationRunner for local exeuction of Samza StreamApplication

----


> LocalApplicationRunner for local exeuction of Samza StreamApplication
> ---------------------------------------------------------------------
>
>                 Key: SAMZA-1132
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1132
>             Project: Samza
>          Issue Type: New Feature
>            Reporter: Xinyu Liu
>            Assignee: Xinyu Liu
>
> LocalRunner execute the StreamApplication locally. In this mode the LocalRunner will run on every node that the application is deployed to. LocalRunner.start() is blocking until user invoke LocalRunner.stop() or an exception happens.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)