[BEAM-595] Support non-blocking run() in SparkRunner and cancel() and waitUntilFinish() in Spark EvaluationContext

• Type: New Feature
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.4.0
• Component/s: runner-spark
• Assignee: Unassigned
• Reporter: Pei He
• Created: 26/Aug/16 18:40
• Updated: 16/May/20 13:36
• Resolved: 05/Dec/16 11:28

Description

We introduced both functions to PipelineResult.
Currently, both of them throw UnsupportedOperationExcedption in Spark runner.

Issue Links

• links to: GitHub Pull Request #1096

Sub-Tasks

• Add non blocking cancel() and waitUntilFinish() for Spark batch application: Resolved
• Add non blocking cancel() and waitUntilFinish() for Spark streaming application: Resolved