This is an automated email from the ASF dual-hosted git repository. yuyuankang pushed a commit to branch exception-master in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4973017a0cdef6b46080caf401448292b6b1b1fb Author: Ring-k <[email protected]> AuthorDate: Fri Jul 23 16:10:34 2021 +0800 remove path registration --- .../main/java/org/apache/iotdb/flink/IoTDBSink.java | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java index 8ab06c0..1daef72 100644 --- a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java +++ b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java @@ -18,17 +18,7 @@ package org.apache.iotdb.flink; -import org.apache.iotdb.flink.options.IoTDBSinkOptions; -import org.apache.iotdb.session.pool.SessionPool; -import org.apache.iotdb.tsfile.common.constant.TsFileConstant; -import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType; - import com.google.common.base.Preconditions; -import org.apache.flink.configuration.Configuration; -import org.apache.flink.streaming.api.functions.sink.RichSinkFunction; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import java.util.ArrayList; import java.util.HashMap; import java.util.LinkedList; @@ -37,6 +27,14 @@ import java.util.Map; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; +import org.apache.flink.configuration.Configuration; +import org.apache.flink.streaming.api.functions.sink.RichSinkFunction; +import org.apache.iotdb.flink.options.IoTDBSinkOptions; +import org.apache.iotdb.session.pool.SessionPool; +import org.apache.iotdb.tsfile.common.constant.TsFileConstant; +import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * The `IoTDBSink` allows flink jobs to write events into IoTDB timeseries. By default send only one
