Skip to content

Commit

Permalink
update current version docs
Browse files Browse the repository at this point in the history
  • Loading branch information
PeterZh6 committed Nov 15, 2024
1 parent 3824ee9 commit d7f23f9
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ Flink SQL> CREATE TABLE kafka_load_node (
'format' = 'csv'
)
```
* 连接器是 `upsert-kafka`
* 连接器是 `upsert-kafka-inlong`
```sql
-- 使用 Flink SQL 创建 Kafka 表 'kafka_load_node'
Flink SQL> CREATE TABLE kafka_load_node (
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ Flink SQL> CREATE TABLE kafka_extract_node (
-- Read data
Flink SQL> SELECT * FROM kafka_extract_node;
```
* connector is `upsert-kafka`
* connector is `upsert-kafka-inlong`
```sql
-- Set checkpoint every 3000 milliseconds
Flink SQL> SET 'execution.checkpointing.interval' = '3s';
Expand Down

0 comments on commit d7f23f9

Please sign in to comment.