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'" +