diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala index 8d5132ba4b1..f72fcadd0fc 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala @@ -159,7 +159,7 @@ class KyuubiSessionImpl( } catch { case e: org.apache.thrift.transport.TTransportException if attempt < maxAttempts && e.getCause.isInstanceOf[java.net.ConnectException] && - e.getCause.getMessage.contains("Connection refused (Connection refused)") => + e.getCause.getMessage.contains("Connection refused") => warn( s"Failed to open [${engine.defaultEngineName} $host:$port] after" + s" $attempt/$maxAttempts times, retrying",