Skip to content

Commit 0311542

Browse files
committed
fix minor
1 parent 77ea002 commit 0311542

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/SparkPlan.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -158,9 +158,8 @@ abstract class SparkPlan extends QueryPlan[SparkPlan] with Logging with Serializ
158158
* Blocks the thread until all subqueries finish evaluation.
159159
*/
160160
protected def waitForSubqueries(): Unit = synchronized {
161-
allSubqueries.foreach { e =>
162-
e.awaitSubqueryResult()
163-
}
161+
allSubqueries.foreach(_.awaitSubqueryResult())
162+
allSubqueries.clear()
164163
}
165164

166165
/**

0 commit comments

Comments
 (0)