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

XML

Word

Printable

JSON

Details

Type: New Feature
Status: Resolved
Priority: P2
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 0.4.0
Component/s: runner-spark
Labels:
None

Description

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

Attachments

Issue Links

links to

GitHub Pull Request #1096

Sub-Tasks

There are no Sub-Tasks for this issue.

Activity

People

Assignee:: Unassigned

Reporter:: Pei He

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 26/Aug/16 18:40

Updated:: 16/May/20 13:36

Resolved:: 05/Dec/16 11:28