diff --git a/java/spark/src/main/java/com/logicalclocks/hsfs/spark/engine/SparkEngine.java b/java/spark/src/main/java/com/logicalclocks/hsfs/spark/engine/SparkEngine.java
index d0326ce2b4..b30bca98c7 100644
--- a/java/spark/src/main/java/com/logicalclocks/hsfs/spark/engine/SparkEngine.java
+++ b/java/spark/src/main/java/com/logicalclocks/hsfs/spark/engine/SparkEngine.java
@@ -1100,11 +1100,7 @@ protected String makeQueryName(String queryName, FeatureGroupBase featureGroup)
   
   public void closeSparkSession() {
     if (getSparkSession() != null) {
-      try {
-        getSparkSession().stop();
-      } catch (Exception e) {
-        // No-OP
-      }
+      getSparkSession().stop();
     }
   }
 }
diff --git a/utils/python/hsfs_utils.py b/utils/python/hsfs_utils.py
index b0a976e63a..3ac632a40b 100644
--- a/utils/python/hsfs_utils.py
+++ b/utils/python/hsfs_utils.py
@@ -294,7 +294,4 @@ def parse_isoformat_date(da: str) -> datetime:
         run_feature_monitoring(job_conf)
 
     if spark is not None:
-        try:
-            spark.stop()
-        except Exception as e:
-            pass
\ No newline at end of file
+        spark.stop()
\ No newline at end of file