From 6c039e753a9031f2a2e37e004f5c1edfe009adad Mon Sep 17 00:00:00 2001 From: Uros Bojanic <221401595+uros-b@users.noreply.github.com> Date: Sat, 8 Aug 2026 09:46:22 +0000 Subject: [PATCH] Initial commit --- .../streaming/state/RocksDBStateStoreProvider.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateStoreProvider.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateStoreProvider.scala index 5cb87bcd070ef..36f64d1175dc0 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateStoreProvider.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateStoreProvider.scala @@ -148,10 +148,10 @@ private[sql] class RocksDBStateStoreProvider case Some(nextState) => nextState case None => val errorMsg = operation match { - case UPDATE => s"Cannot update after ${oldState.toString}" - case ABORT => s"Cannot abort after ${oldState.toString}" - case RELEASE => s"Cannot release after ${oldState.toString}" - case COMMIT => s"Cannot commit after ${oldState.toString}" + case UPDATE => s"Cannot update after ${oldState}" + case ABORT => s"Cannot abort after ${oldState}" + case RELEASE => s"Cannot release after ${oldState}" + case COMMIT => s"Cannot commit after ${oldState}" case METRICS => s"Cannot get metrics in ${oldState} state" } throw StateStoreErrors.stateStoreOperationOutOfOrder(errorMsg)