From 331d847bfea68cb25564d59c5722108fb97f5447 Mon Sep 17 00:00:00 2001 From: Nicole00 Date: Fri, 17 Dec 2021 13:59:33 +0800 Subject: [PATCH] release the transport when version verification failed --- .../com/vesoft/nebula/client/graph/net/SyncConnection.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/client/src/main/java/com/vesoft/nebula/client/graph/net/SyncConnection.java b/client/src/main/java/com/vesoft/nebula/client/graph/net/SyncConnection.java index 07e625aae..4216e684c 100644 --- a/client/src/main/java/com/vesoft/nebula/client/graph/net/SyncConnection.java +++ b/client/src/main/java/com/vesoft/nebula/client/graph/net/SyncConnection.java @@ -78,6 +78,7 @@ public void open(HostAddress address, int timeout, SSLParam sslParam) Charsets.UTF_8)); } } catch (TException | IOException e) { + close(); throw new IOErrorException(IOErrorException.E_UNKNOWN, e.getMessage()); } } @@ -224,7 +225,7 @@ public boolean ping() { } public void close() { - if (transport != null) { + if (transport != null && transport.isOpen()) { transport.close(); } }