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

Posted to commits@samza.apache.org by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/05/19 23:40:04 UTC

[jira] [Created] (SAMZA-1303) Request for waitForFinish(time, TimeUnit) api in LocalApplicationRunner

Shanthoosh Venkataraman created SAMZA-1303:
----------------------------------------------

             Summary: Request for waitForFinish(time, TimeUnit) api in LocalApplicationRunner
                 Key: SAMZA-1303
                 URL: https://issues.apache.org/jira/browse/SAMZA-1303
             Project: Samza
          Issue Type: Improvement
            Reporter: Shanthoosh Venkataraman
            Priority: Minor


LocalApplicationRunner is used to launch stream applications in standalone mode in samza. 

Existing waitForFinish() API in LocalApplicationRunner waits indefinitely for a stream application to terminate. 

It will improve API usability if we add awaitFinish(awaitTime, TimeUnit) to LocalApplicationRunner.

This will help write better tests (Transient Thread.sleep in tests are not required) and will improve the control of terminating stream application.



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