Skip to content

Commit f456207

Browse files
committed
Update SparkSession.scala
1 parent f4d5aa4 commit f456207

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -600,6 +600,7 @@ class SparkSession private(
600600
* @since 2.0.0
601601
*/
602602
def sql(sqlText: String): DataFrame = {
603+
SparkSession.setActiveSession(this)
603604
val tracker = new QueryPlanningTracker
604605
val plan = tracker.measurePhase(QueryPlanningTracker.PARSING) {
605606
sessionState.sqlParser.parsePlan(sqlText)

0 commit comments

Comments
 (0)