Skip to content

Commit 3b67be7

Browse files
committed
remove unused code and irrelevant comment
1 parent f2826b4 commit 3b67be7

File tree

2 files changed

+1
-16
lines changed

2 files changed

+1
-16
lines changed

sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/PipelineExecution.scala

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,6 @@
1717

1818
package org.apache.spark.sql.pipelines.graph
1919

20-
import scala.annotation.unused
21-
2220
import org.apache.spark.sql.pipelines.logging.{ConstructPipelineEvent, EventLevel, PipelineEventOrigin, RunProgress}
2321

2422
/**
@@ -109,17 +107,4 @@ class PipelineExecution(context: PipelineUpdateContext) {
109107
)
110108
}
111109
}
112-
113-
@unused(
114-
"TODO(SPARK-51727): connect this API with spark connect backend and expose it to the user"
115-
)
116-
def stopPipeline(): Unit = synchronized {
117-
graphExecution
118-
.getOrElse(
119-
throw new IllegalStateException(
120-
"Pipeline execution has not started yet."
121-
)
122-
)
123-
.stop()
124-
}
125110
}

sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/TriggeredGraphExecution.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ class TriggeredGraphExecution(
110110
val thread = buildTopologicalExecutionThread()
111111
UncaughtExceptionHandler.addHandler(
112112
thread, {
113-
case _: InterruptedException => // stop from UI leads to InterruptedException. Do nothing.
113+
case _: InterruptedException =>
114114
case _ =>
115115
try {
116116
stopInternal(stopTopologicalExecutionThread = false)

0 commit comments

Comments
 (0)