This is an automated email from the ASF dual-hosted git repository.
chengpan pushed a commit to branch branch-1.7
in repository https://gitbox.apache.org/repos/asf/kyuubi.git
The following commit(s) were added to refs/heads/branch-1.7 by this push:
new b2b9d2888 [KYUUBI #4855] Change socket "connection refused" message
match pattern
b2b9d2888 is described below
commit b2b9d28882519cfebd8801394ab2abd962dc299e
Author: Cheng Pan <[email protected]>
AuthorDate: Fri May 19 12:03:05 2023 +0800
[KYUUBI #4855] Change socket "connection refused" message match pattern
### _Why are the changes needed?_
The error message changed in JDK 17, we should change the match pattern
accordingly.
### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including
negative and positive cases if possible
- [ ] Add screenshots for manual tests if appropriate
- [x] [Run
test](https://kyuubi.readthedocs.io/en/master/develop_tools/testing.html#running-tests)
locally before make a pull request
Closes #4855 from pan3793/conn-refuse.
Closes #4855
78178b140 [Cheng Pan] Change socket "connection refused" message match
pattern
Authored-by: Cheng Pan <[email protected]>
Signed-off-by: Cheng Pan <[email protected]>
(cherry picked from commit cd47b131276d8a20fbd4a371bba9fcc42eca781d)
Signed-off-by: Cheng Pan <[email protected]>
---
.../src/main/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 80df5c44d..9f54cbc12 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
@@ -161,7 +161,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",
