You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yu...@apache.org on 2021/07/15 06:27:06 UTC
[iotdb] 02/02: remve series registeration
This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a commit to branch IoTDB-1499-0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e5b8502fc5cfa9206453b6e774c82b19e4110cc5
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Thu Jul 15 14:26:18 2021 +0800
remve series registeration
---
docs/UserGuide/Ecosystem Integration/Flink IoTDB.md | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/docs/UserGuide/Ecosystem Integration/Flink IoTDB.md b/docs/UserGuide/Ecosystem Integration/Flink IoTDB.md
index 41cfbce..5a5520a 100644
--- a/docs/UserGuide/Ecosystem Integration/Flink IoTDB.md
+++ b/docs/UserGuide/Ecosystem Integration/Flink IoTDB.md
@@ -35,6 +35,8 @@ This example shows a case that sends data to a IoTDB server from a Flink job:
- A simulated Source `SensorSource` generates data points per 1 second.
- Flink uses `IoTDBSink` to consume the generated data points and write the data into IoTDB.
+It is noteworthy that to use IoTDBSink, schema auto-creation in IoTDB should be enabled.
+
```java
import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
@@ -59,7 +61,6 @@ public class FlinkIoTDBSink {
options.setPort(6667);
options.setUser("root");
options.setPassword("root");
- options.setStorageGroup("root.sg");
// If the server enables auto_create_schema, then we do not need to register all timeseries
// here.