throw the exception

eason-yuchen-liu · Jun 27, 2024 · 4deb63e · 4deb63e
1 parent 6f1425d
commit 4deb63e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...main/scala/org/apache/spark/sql/execution/datasources/v2/state/StatePartitionReader.scala b/...main/scala/org/apache/spark/sql/execution/datasources/v2/state/StatePartitionReader.scala
@@ -98,7 +98,7 @@ class StatePartitionReader(
 
       case Some(snapshotStartBatchId) =>
         if (!provider.isInstanceOf[SupportsFineGrainedReplay]) {
-          StateStoreErrors.stateStoreProviderDoesNotSupportFineGrainedReplay(
+          throw StateStoreErrors.stateStoreProviderDoesNotSupportFineGrainedReplay(
             provider.getClass.toString)
         }
         provider.asInstanceOf[SupportsFineGrainedReplay]

diff --git a/.../scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala b/.../scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala
@@ -494,7 +494,7 @@ class SymmetricHashJoinStateManager(
           useMultipleValuesPerKey = false)
         if (snapshotStartVersion.isDefined) {
           if (!stateStoreProvider.isInstanceOf[SupportsFineGrainedReplay]) {
-            StateStoreErrors.stateStoreProviderDoesNotSupportFineGrainedReplay(
+            throw StateStoreErrors.stateStoreProviderDoesNotSupportFineGrainedReplay(
               stateStoreProvider.getClass.toString)
           }
           stateStoreProvider.asInstanceOf[SupportsFineGrainedReplay]