Skip to content

Commit ef92de0

Browse files
tkaymakTobias Kaymak
authored andcommitted
Add cancellation support to Spark pipeline execution
1 parent d6c79d8 commit ef92de0

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

runners/spark/4/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineResult.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,7 @@ public MetricResults metrics() {
113113

114114
@Override
115115
public PipelineResult.State cancel() throws IOException {
116+
pipelineExecution.cancel(true);
116117
offerNewState(PipelineResult.State.CANCELLED);
117118
return state;
118119
}

0 commit comments

Comments
 (0)