File tree Expand file tree Collapse file tree 2 files changed +1
-16
lines changed
sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph Expand file tree Collapse file tree 2 files changed +1
-16
lines changed Original file line number Diff line number Diff line change 17
17
18
18
package org .apache .spark .sql .pipelines .graph
19
19
20
- import scala .annotation .unused
21
-
22
20
import org .apache .spark .sql .pipelines .logging .{
23
21
ConstructPipelineEvent ,
24
22
EventLevel ,
@@ -115,17 +113,4 @@ class PipelineExecution(context: PipelineUpdateContext) {
115
113
)
116
114
}
117
115
}
118
-
119
- @ unused(
120
- " TODO(SPARK-51727): connect this API with spark connect backend and expose it to the user"
121
- )
122
- def stopPipeline (): Unit = synchronized {
123
- graphExecution
124
- .getOrElse(
125
- throw new IllegalStateException (
126
- " Pipeline execution has not started yet."
127
- )
128
- )
129
- .stop()
130
- }
131
116
}
Original file line number Diff line number Diff line change @@ -110,7 +110,7 @@ class TriggeredGraphExecution(
110
110
val thread = buildTopologicalExecutionThread()
111
111
UncaughtExceptionHandler .addHandler(
112
112
thread, {
113
- case _ : InterruptedException => // stop from UI leads to InterruptedException. Do nothing.
113
+ case _ : InterruptedException =>
114
114
case _ =>
115
115
try {
116
116
stopInternal(stopTopologicalExecutionThread = false )
You can’t perform that action at this time.
0 commit comments