From 88dbdf1290d495aef0f2b57b55642c83594f09e0 Mon Sep 17 00:00:00 2001 From: menshibin Date: Mon, 10 Feb 2025 17:07:45 +0800 Subject: [PATCH] fix:modify table sql mode config --- docs/examples/flink/Main.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/examples/flink/Main.java b/docs/examples/flink/Main.java index 50a507d1de..dfa73bb45d 100644 --- a/docs/examples/flink/Main.java +++ b/docs/examples/flink/Main.java @@ -559,7 +559,7 @@ splitSql.setSelect("ts, current, voltage, phase, groupid, location") " tbname VARBINARY" + ") WITH (" + " 'connector' = 'tdengine-connector'," + - " 'td.jdbc.mode' = 'cdc'," + + " 'td.jdbc.mode' = 'sink'," + " 'td.jdbc.url' = 'jdbc:TAOS-WS://localhost:6041/power_sink?user=root&password=taosdata'," + " 'sink.db.name' = 'power_sink'," + " 'sink.supertable.name' = 'sink_meters'" +