From 78178b1402f759977f4611534d969dba2d682c78 Mon Sep 17 00:00:00 2001 From: Cheng Pan Date: Thu, 18 May 2023 12:18:36 +0800 Subject: [PATCH] Change socket "connection refused" message match pattern --- .../scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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",