diff --git a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/operation/ExecuteStatement.scala b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/operation/ExecuteStatement.scala index 312161c11bb..7ac483b2b4f 100644 --- a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/operation/ExecuteStatement.scala +++ b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/operation/ExecuteStatement.scala @@ -223,7 +223,7 @@ class ExecuteStatement( executor.cancelQuery(sessionId, resultId) } catch { case t: Throwable => - warn("Failed to clean result set " + resultId + " in session " + sessionId, t) + warn(s"Failed to clean result set $resultId in session $sessionId", t) } }