diff --git a/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectExecutionManager.scala b/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectExecutionManager.scala index 2a936b526d96..091dfb671667 100644 --- a/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectExecutionManager.scala +++ b/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectExecutionManager.scala @@ -159,7 +159,6 @@ private[connect] class SparkConnectExecutionManager() extends Logging { // getting an INVALID_HANDLE.OPERATION_ABANDONED error on a retry. if (abandoned) { abandonedTombstones.put(key, executeHolder.getExecuteInfo) - executeHolder.sessionHolder.closeOperation(executeHolder) } // Remove the execution from the map *after* putting it in abandonedTombstones.