[iotdb] branch flink_iotdb updated: open session

[yuyuankang]

This is an automated email from the ASF dual-hosted git repository.

yuyuankang pushed a commit to branch flink_iotdb
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/flink_iotdb by this push:
     new 9ceda3e  open session
9ceda3e is described below

commit 9ceda3e5facf5895eaa90ac965b65b9204e1c47f
Author: Ring-k <yuyuank...@hotmail.com>
AuthorDate: Thu Apr 1 20:52:52 2021 +0800

    open session
---
 .../src/main/java/org/apache/iotdb/flink/IoTDBSource.java                | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java 
b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java
index 816cf89..74550eb 100644
--- 
a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java
+++ 
b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSource.java
@@ -90,5 +90,6 @@ public abstract class IoTDBSource<T> extends 
RichSourceFunction<T> {
             sourceOptions.getPort(),
             sourceOptions.getUser(),
             sourceOptions.getPassword());
+    session.open();
   }
 }