Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1653

Support waitForFinish() in remote and add duration to both

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 0.14.1
    • None
    • None

    Description

      WE need the consistent api for waitForFinish() in remote runner. This is for two reasons:

      1. feature parity with local runner
      2. for future use case if we support submit a batch job to a remote cluster and allow user program to wait till it completes to check the output.

      We need another variant of waitForFinish(duration). This is to be compatible with BEAM API. 

      Attachments

        Issue Links

          Activity

            People

              bharathkk Bharath Kumarasubramanian
              xinyu Xinyu Liu
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: