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 863b7563ff7 [hotfix][docs] Fix missed documentation during flink-web
migrate to Hugo by FLINK-11293
863b7563ff7 is described below
commit 863b7563ff78d9af242515963e2787a99cec54ed
Author: Leonard Xu <[email protected]>
AuthorDate: Mon Nov 17 20:49:02 2025 +0800
[hotfix][docs] Fix missed documentation during flink-web migrate to Hugo by
FLINK-11293
This closes #27244.
---
docs/content.zh/docs/connectors/table/formats/canal.md | 10 +++++++++-
docs/content/docs/connectors/table/formats/canal.md | 10 +++++++++-
2 files changed, 18 insertions(+), 2 deletions(-)
diff --git a/docs/content.zh/docs/connectors/table/formats/canal.md
b/docs/content.zh/docs/connectors/table/formats/canal.md
index d7630f94f42..9ceb3ccc53d 100644
--- a/docs/content.zh/docs/connectors/table/formats/canal.md
+++ b/docs/content.zh/docs/connectors/table/formats/canal.md
@@ -178,6 +178,12 @@ metadata fields for its value format.
<td>The timestamp at which the connector processed the event.
Corresponds to the <code>ts</code>
field in the Canal record.</td>
</tr>
+ <tr>
+ <td><code>event-timestamp</code></td>
+ <td><code>TIMESTAMP(3) WITH LOCAL TIME ZONE NULL</code></td>
+ <td>The timestamp when the corresponding change was executed in MySQL
server. Corresponds to the <code>es</code>
+ field in the Canal record.</td>
+ </tr>
</tbody>
</table>
@@ -190,9 +196,11 @@ CREATE TABLE KafkaTable (
origin_sql_type MAP<STRING, INT> METADATA FROM 'value.sql-type' VIRTUAL,
origin_pk_names ARRAY<STRING> METADATA FROM 'value.pk-names' VIRTUAL,
origin_ts TIMESTAMP(3) METADATA FROM 'value.ingestion-timestamp' VIRTUAL,
+ origin_es TIMESTAMP(3) METADATA FROM 'value.event-timestamp' VIRTUAL,
user_id BIGINT,
item_id BIGINT,
- behavior STRING
+ behavior STRING,
+ WATERMARK FOR origin_es AS origin_es - INTERVAL '5' SECOND
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
diff --git a/docs/content/docs/connectors/table/formats/canal.md
b/docs/content/docs/connectors/table/formats/canal.md
index 2373fa19479..6f253125e49 100644
--- a/docs/content/docs/connectors/table/formats/canal.md
+++ b/docs/content/docs/connectors/table/formats/canal.md
@@ -181,6 +181,12 @@ metadata fields for its value format.
<td>The timestamp at which the connector processed the event.
Corresponds to the <code>ts</code>
field in the Canal record.</td>
</tr>
+ <tr>
+ <td><code>event-timestamp</code></td>
+ <td><code>TIMESTAMP(3) WITH LOCAL TIME ZONE NULL</code></td>
+ <td>The timestamp when the corresponding change was executed in MySQL
server. Corresponds to the <code>es</code>
+ field in the Canal record.</td>
+ </tr>
</tbody>
</table>
@@ -193,9 +199,11 @@ CREATE TABLE KafkaTable (
origin_sql_type MAP<STRING, INT> METADATA FROM 'value.sql-type' VIRTUAL,
origin_pk_names ARRAY<STRING> METADATA FROM 'value.pk-names' VIRTUAL,
origin_ts TIMESTAMP(3) METADATA FROM 'value.ingestion-timestamp' VIRTUAL,
+ origin_es TIMESTAMP(3) METADATA FROM 'value.event-timestamp' VIRTUAL,
user_id BIGINT,
item_id BIGINT,
- behavior STRING
+ behavior STRING,
+ WATERMARK FOR origin_es AS origin_es - INTERVAL '5' SECOND
) WITH (
'connector' = 'kafka',
'topic' = 'user_behavior',
