Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
WE need the consistent api for waitForFinish() in remote runner. This is for two reasons:
- feature parity with local runner
- 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
- links to