From 3186e1ab0b6c9abc7f06b40f4d096d89077e3e6e Mon Sep 17 00:00:00 2001
From: Gibson Chikafa <gibbschikafa@gmail.com>
Date: Wed, 10 Jul 2024 09:05:43 +0200
Subject: [PATCH] Do not catch exception

---
 .../com/logicalclocks/hsfs/spark/engine/SparkEngine.java    | 6 +-----
 utils/python/hsfs_utils.py                                  | 5 +----
 2 files changed, 2 insertions(+), 9 deletions(-)

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