[jira] [Assigned] (BEAM-647) Fault-tolerant sideInputs via Broadcast variables

[ https://issues.apache.org/jira/browse/BEAM-647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kobi Salant reassigned BEAM-647: Assignee: Kobi Salant (was: Amit Sela) > Fault-tolerant sideInputs via Broadcast variables >

[jira] [Created] (BEAM-1048) Spark Runner streaming batch duration does not include duration of reading from source

Kobi Salant created BEAM-1048: - Summary: Spark Runner streaming batch duration does not include duration of reading from source Key: BEAM-1048 URL: https://issues.apache.org/jira/browse/BEAM-1048

[jira] [Updated] (BEAM-1001) Add non blocking cancel() and waitUntilFinish() for Spark streaming application

[ https://issues.apache.org/jira/browse/BEAM-1001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kobi Salant updated BEAM-1001: -- Description: Spark streaming submit by nature is non blocking. It is straight forward implementation

[jira] [Assigned] (BEAM-1001) Add non blocking cancel() and waitUntilFinish() for Spark streaming application

[ https://issues.apache.org/jira/browse/BEAM-1001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kobi Salant reassigned BEAM-1001: - Assignee: Kobi Salant > Add non blocking cancel() and waitUntilFinish() for Spark streaming >

[jira] [Created] (BEAM-1001) Add non blocking cancel() and waitUntilFinish() for Spark streaming application

Kobi Salant created BEAM-1001: - Summary: Add non blocking cancel() and waitUntilFinish() for Spark streaming application Key: BEAM-1001 URL: https://issues.apache.org/jira/browse/BEAM-1001 Project: Beam

[jira] [Created] (BEAM-1000) Add non blocking cancel() and waitUntilFinish() for Spark batch application

Kobi Salant created BEAM-1000: - Summary: Add non blocking cancel() and waitUntilFinish() for Spark batch application Key: BEAM-1000 URL: https://issues.apache.org/jira/browse/BEAM-1000 Project: Beam