diff --git a/connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala b/connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala index e4b60eeeff0d6..e96e5dfcac089 100644 --- a/connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala +++ b/connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala @@ -191,7 +191,7 @@ class SparkConnectService(debug: Boolean) extends AsyncService with BindableServ new SparkConnectReleaseExecuteHandler(responseObserver).handle(request) } catch ErrorUtils.handleError( - "reattachExecute", + "releaseExecute", observer = responseObserver, userId = request.getUserContext.getUserId, sessionId = request.getSessionId)