You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@auron.apache.org by zu...@apache.org on 2025/10/17 03:30:12 UTC
(auron) branch master updated: [AURON #1409] followup to always get active context (#1433)
This is an automated email from the ASF dual-hosted git repository.
zuston pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/auron.git
The following commit(s) were added to refs/heads/master by this push:
new 05b8939c [AURON #1409] followup to always get active context (#1433)
05b8939c is described below
commit 05b8939cc35cedc045abe36dc540123884daaf85
Author: Junfan Zhang <zu...@apache.org>
AuthorDate: Fri Oct 17 11:30:08 2025 +0800
[AURON #1409] followup to always get active context (#1433)
Co-authored-by: Zhen Wang <64...@qq.com>
---
.../src/main/scala/org/apache/spark/sql/auron/ShimsImpl.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/auron/ShimsImpl.scala b/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/auron/ShimsImpl.scala
index 0ba63c8e..1e2533f1 100644
--- a/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/auron/ShimsImpl.scala
+++ b/spark-extension-shims-spark3/src/main/scala/org/apache/spark/sql/auron/ShimsImpl.scala
@@ -158,7 +158,9 @@ class ShimsImpl extends Shims with Logging {
.get(AuronConf.UI_ENABLED.key, "true"))
if (SparkEnv.get.conf.get(AuronConf.UI_ENABLED.key, "true").equals("true")) {
- val sparkContext = SparkContext.getOrCreate()
+ val sparkContext = SparkContext.getActive.getOrElse {
+ throw new IllegalStateException("No active spark context found that should not happen")
+ }
val kvStore = sparkContext.statusStore.store.asInstanceOf[ElementTrackingStore]
val statusStore = new AuronSQLAppStatusStore(kvStore)
sparkContext.ui.foreach(new AuronSQLTab(statusStore, _))