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

Posted to dev@samza.apache.org by bharathkk <gi...@git.apache.org> on 2018/05/04 15:30:01 UTC

[GitHub] samza pull request #503: SAMZA-1653: Support waitForFinish in remote applica...

GitHub user bharathkk opened a pull request:

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

    SAMZA-1653: Support waitForFinish in remote application runner and add waitForFinish

    Added the following APIs to AbstractApplicationRunner 
     `void waitForFinish()`
     `void waitForFinish(Duration timeout)`
    
    Implemented the wait for finish methods in remote application runner. Note currently, there is disparity in the APIs in terms of associating runners with stream application. Ideally, we want to decide on the cardinal relation between them and change the APIs accordingly. 
    
    The goal of the PR is limited to introduce API (waitForFinish) parity between runners in the current setup. 
    @xinyuiscool 

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

    $ git pull https://github.com/bharathkk/samza samza-1653

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

    https://github.com/apache/samza/pull/503.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 #503
    
----
commit b8c3129054cf3f3adcac2d5196e46e3ecac31ee9
Author: Bharath Kumarasubramanian <bk...@...>
Date:   2018-04-30T16:22:39Z

    Support waitForFinish in remote application runner and add waitForFinish with duration

----


---

[GitHub] samza pull request #503: SAMZA-1653: Support waitForFinish in remote applica...

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

Github user asfgit closed the pull request at:

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


---