iotdb
iotdb copied to clipboard
apache
请教flink-sql-iotdb-connector连接器写入iotdb的sql案例
请问下: 看文档介绍从1.2开始支持flinksql的连接器了，但是无法引入该jar
<dependency>
<groupId>org.apache.iotdb</groupId>
<artifactId>flink-sql-iotdb-connector</artifactId>
<version>${iotdb.version}</version>
</dependency>
maven仓库没有该jar？这个jar如何引入。
另外，flink-sql-iotdb-connector 的sql形式案例有没有？例如：
`-- register a MySQL table 'users' in Flink SQL
CREATE TABLE MyUserTable (
id BIGINT,
name STRING,
age INT,
status BOOLEAN,
PRIMARY KEY (id) NOT ENFORCED
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://localhost:3306/mydatabase',
'table-name' = 'users'
);`
那么想从kafka消费数据写入iotdb，请问怎么写呢？谢谢
Flink SQL的连接器要等到1.2.2才会开始正式的支持。如果现在想要体验的话，可以把源码拉下来，可以在master分支或者rel/1.2分支，用mvn install -DskipTests命令编译安装一下。
Flink SQL的连接器要等到1.2.2才会开始正式的支持。如果现在想要体验的话，可以把源码拉下来，可以在master分支或者rel/1.2分支，用mvn install -DskipTests命令编译安装一下。
感谢，那么服务是不是也要升级到1.2.2？
Flink SQL的连接器要等到1.2.2才会开始正式的支持。如果现在想要体验的话，可以把源码拉下来，可以在master分支或者rel/1.2分支，用mvn install -DskipTests命令编译安装一下。
感谢，那么服务是不是也要升级到1.2.2？
是的，服务也要升级到 1.2.2 或者 master @bigdata-spec
Flink SQL的连接器要等到1.2.2才会开始正式的支持。如果现在想要体验的话，可以把源码拉下来，可以在master分支或者rel/1.2分支，用mvn install -DskipTests命令编译安装一下。
感谢，那么服务是不是也要升级到1.2.2？
是的，服务也要升级到 1.2.2 或者 master @bigdata-spec
谢谢，我看maven中央仓库iotdb的iotdb-session等包版本都比较老，1.0.0后续考虑更新吗？
Flink SQL的连接器要等到1.2.2才会开始正式的支持。如果现在想要体验的话，可以把源码拉下来，可以在master分支或者rel/1.2分支，用mvn install -DskipTests命令编译安装一下。
感谢，那么服务是不是也要升级到1.2.2？
是的，服务也要升级到 1.2.2 或者 master @bigdata-spec
您好，后续会有sql一样的demo吗？如
`-- register a MySQL table 'users' in Flink SQL
CREATE TABLE MyUserTable (
id BIGINT,
name STRING,
age INT,
status BOOLEAN,
PRIMARY KEY (id) NOT ENFORCED
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://localhost:3306/mydatabase',
'table-name' = 'users'
);
-- write data into the JDBC table from the other table "T"
INSERT INTO MyUserTable
SELECT id, name, age, status FROM T;
-- scan data from the JDBC table
SELECT id, name, age, status FROM MyUserTable;
-- temporal join the JDBC table as a dimension table
SELECT * FROM myTopic
LEFT JOIN MyUserTable FOR SYSTEM_TIME AS OF myTopic.proctime
ON myTopic.key = MyUserTable.id;`
@SteveYurongSu @wanghui42 Hello，官网flink-sql-connector的demo cdc运行不报错也没数据。是不是demo有问题？