flinksql实现iotdbcdc的问题咨询 #13408

fmiaojie · 2024-09-05T01:55:27Z

fmiaojie
Sep 5, 2024

怎么使用flinksql实现iotdb的cdc：
CREATE TABLE iotdb_table2 (
Time_ BIGINT,
root.test.sn INT,
root.test.T DOUBLE,
root.test.x DOUBLE,
root.test.y DOUBLE
) WITH (
'connector' = 'IoTDB',
'nodeUrls' = '192.168.10.52:6667',
'user' = 'root',
'password' = 'root',
'mode' = 'CDC',
'cdc.task.name' = 'test',
'sql' = 'SELECT Time_, sn, T, x, y FROM root.test',
'cdc.pattern' = 'root.test'
);

CREATE TABLE JDBC_table4 (
Time_ BIGINT,
sn INT,
temperature DOUBLE,
x DOUBLE,
y DOUBLE
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://192.168.61.128:3306/target?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true',
'table-name' = 'iotdb2',
'username' = 'root',
'password' = '@As200228'
);

INSERT INTO
JDBC_table4
SELECT
Time_,
root.test.sn AS sn,
root.test.T AS temperature,
root.test.x AS x,
root.test.y AS y
FROM
iotdb_table2;

我使用以上语句，运行时没有报错，但是也没有进行数据传输