You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ga...@apache.org on 2022/10/12 14:03:38 UTC
[incubator-seatunnel] branch dev updated: [Bug][Connector-v2] Fix IoTDB connector sink NPE (#3080)
This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new e5edf0243 [Bug][Connector-v2] Fix IoTDB connector sink NPE (#3080)
e5edf0243 is described below
commit e5edf0243387e9df87792028e55d85f772504efa
Author: hailin0 <wa...@apache.org>
AuthorDate: Wed Oct 12 22:03:32 2022 +0800
[Bug][Connector-v2] Fix IoTDB connector sink NPE (#3080)
---
.../seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSinkClient.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSinkClient.java b/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSinkClient.java
index a9b095496..91b3461da 100644
--- a/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSinkClient.java
+++ b/seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSinkClient.java
@@ -124,7 +124,9 @@ public class IoTDBSinkClient {
flush();
try {
- session.close();
+ if (session != null) {
+ session.close();
+ }
} catch (IoTDBConnectionException e) {
log.error("Close IoTDB client failed.", e);
throw new IOException("Close IoTDB client failed.", e);