This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new fc63153031d [FLINK-32289][docs][kafka] Fix incorrect metadata column
type in Kafka table connector examples
fc63153031d is described below
commit fc63153031d3b45917b080a462741237b6a2d639
Author: yuxiqian <[email protected]>
AuthorDate: Tue Jun 13 11:29:22 2023 +0800
[FLINK-32289][docs][kafka] Fix incorrect metadata column type in Kafka
table connector examples
This closes ##22760.
---
docs/content.zh/docs/connectors/table/kafka.md | 14 +++++++-------
docs/content/docs/connectors/table/kafka.md | 14 +++++++-------
2 files changed, 14 insertions(+), 14 deletions(-)
diff --git a/docs/content.zh/docs/connectors/table/kafka.md
b/docs/content.zh/docs/connectors/table/kafka.md
index 9af7f8a6ae1..635c5e14dab 100644
--- a/docs/content.zh/docs/connectors/table/kafka.md
+++ b/docs/content.zh/docs/connectors/table/kafka.md
@@ -49,7 +49,7 @@ CREATE TABLE KafkaTable (
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING,
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp'
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
@@ -128,7 +128,7 @@ CREATE TABLE KafkaTable (
```sql
CREATE TABLE KafkaTable (
- `event_time` TIMESTAMP(3) METADATA FROM 'timestamp',
+ `event_time` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp',
`partition` BIGINT METADATA VIRTUAL,
`offset` BIGINT METADATA VIRTUAL,
`user_id` BIGINT,
@@ -152,7 +152,7 @@ CREATE TABLE KafkaTable (
```sql
CREATE TABLE KafkaTable (
- `event_time` TIMESTAMP(3) METADATA FROM 'value.source.timestamp' VIRTUAL,
-- from Debezium format
+ `event_time` TIMESTAMP_LTZ(3) METADATA FROM 'value.source.timestamp'
VIRTUAL, -- from Debezium format
`origin_table` STRING METADATA FROM 'value.source.table' VIRTUAL, -- from
Debezium format
`partition_id` BIGINT METADATA FROM 'partition' VIRTUAL, -- from Kafka
connector
`offset` BIGINT METADATA VIRTUAL, -- from Kafka connector
@@ -390,7 +390,7 @@ Kafka 消息的消息键和消息体部分都可以使用某种 [格式]({{< ref
```sql
CREATE TABLE KafkaTable (
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp',
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp',
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING
@@ -416,7 +416,7 @@ ROW<`user_id` BIGINT, `item_id` BIGINT, `behavior` STRING>
```sql
CREATE TABLE KafkaTable (
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp',
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp',
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING
@@ -580,7 +580,7 @@ CREATE TABLE KafkaTable (
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING,
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp'
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
...
@@ -595,7 +595,7 @@ CREATE TABLE KafkaTable (
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING,
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp'
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
...
diff --git a/docs/content/docs/connectors/table/kafka.md
b/docs/content/docs/connectors/table/kafka.md
index a110ad8f51d..1bdf3ca8c56 100644
--- a/docs/content/docs/connectors/table/kafka.md
+++ b/docs/content/docs/connectors/table/kafka.md
@@ -51,7 +51,7 @@ CREATE TABLE KafkaTable (
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING,
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp'
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
@@ -130,7 +130,7 @@ The extended `CREATE TABLE` example demonstrates the syntax
for exposing these m
```sql
CREATE TABLE KafkaTable (
- `event_time` TIMESTAMP(3) METADATA FROM 'timestamp',
+ `event_time` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp',
`partition` BIGINT METADATA VIRTUAL,
`offset` BIGINT METADATA VIRTUAL,
`user_id` BIGINT,
@@ -155,7 +155,7 @@ The following example shows how to access both Kafka and
Debezium metadata field
```sql
CREATE TABLE KafkaTable (
- `event_time` TIMESTAMP(3) METADATA FROM 'value.source.timestamp' VIRTUAL,
-- from Debezium format
+ `event_time` TIMESTAMP_LTZ(3) METADATA FROM 'value.source.timestamp'
VIRTUAL, -- from Debezium format
`origin_table` STRING METADATA FROM 'value.source.table' VIRTUAL, -- from
Debezium format
`partition_id` BIGINT METADATA FROM 'partition' VIRTUAL, -- from Kafka
connector
`offset` BIGINT METADATA VIRTUAL, -- from Kafka connector
@@ -436,7 +436,7 @@ options are prefixed with the format identifier.
```sql
CREATE TABLE KafkaTable (
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp',
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp',
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING
@@ -462,7 +462,7 @@ prefixed with either the `'key'` or `'value'` plus format
identifier.
```sql
CREATE TABLE KafkaTable (
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp',
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp',
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING
@@ -636,7 +636,7 @@ CREATE TABLE KafkaTable (
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING,
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp'
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
...
@@ -651,7 +651,7 @@ CREATE TABLE KafkaTable (
`user_id` BIGINT,
`item_id` BIGINT,
`behavior` STRING,
- `ts` TIMESTAMP(3) METADATA FROM 'timestamp'
+ `ts` TIMESTAMP_LTZ(3) METADATA FROM 'timestamp'
) WITH (
'connector' = 'kafka',
...
