Skip to content

Commit 863b756

Browse files
authored
[hotfix][docs] Fix missed documentation during flink-web migrate to Hugo by FLINK-11293
This closes #27244.
1 parent fd7e2a1 commit 863b756

File tree

2 files changed

+18
-2
lines changed
  • docs
    • content.zh/docs/connectors/table/formats
    • content/docs/connectors/table/formats

2 files changed

+18
-2
lines changed

docs/content.zh/docs/connectors/table/formats/canal.md

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,6 +178,12 @@ metadata fields for its value format.
178178
<td>The timestamp at which the connector processed the event. Corresponds to the <code>ts</code>
179179
field in the Canal record.</td>
180180
</tr>
181+
<tr>
182+
<td><code>event-timestamp</code></td>
183+
<td><code>TIMESTAMP(3) WITH LOCAL TIME ZONE NULL</code></td>
184+
<td>The timestamp when the corresponding change was executed in MySQL server. Corresponds to the <code>es</code>
185+
field in the Canal record.</td>
186+
</tr>
181187
</tbody>
182188
</table>
183189

@@ -190,9 +196,11 @@ CREATE TABLE KafkaTable (
190196
origin_sql_type MAP<STRING, INT> METADATA FROM 'value.sql-type' VIRTUAL,
191197
origin_pk_names ARRAY<STRING> METADATA FROM 'value.pk-names' VIRTUAL,
192198
origin_ts TIMESTAMP(3) METADATA FROM 'value.ingestion-timestamp' VIRTUAL,
199+
origin_es TIMESTAMP(3) METADATA FROM 'value.event-timestamp' VIRTUAL,
193200
user_id BIGINT,
194201
item_id BIGINT,
195-
behavior STRING
202+
behavior STRING,
203+
WATERMARK FOR origin_es AS origin_es - INTERVAL '5' SECOND
196204
) WITH (
197205
'connector' = 'kafka',
198206
'topic' = 'user_behavior',

docs/content/docs/connectors/table/formats/canal.md

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -181,6 +181,12 @@ metadata fields for its value format.
181181
<td>The timestamp at which the connector processed the event. Corresponds to the <code>ts</code>
182182
field in the Canal record.</td>
183183
</tr>
184+
<tr>
185+
<td><code>event-timestamp</code></td>
186+
<td><code>TIMESTAMP(3) WITH LOCAL TIME ZONE NULL</code></td>
187+
<td>The timestamp when the corresponding change was executed in MySQL server. Corresponds to the <code>es</code>
188+
field in the Canal record.</td>
189+
</tr>
184190
</tbody>
185191
</table>
186192

@@ -193,9 +199,11 @@ CREATE TABLE KafkaTable (
193199
origin_sql_type MAP<STRING, INT> METADATA FROM 'value.sql-type' VIRTUAL,
194200
origin_pk_names ARRAY<STRING> METADATA FROM 'value.pk-names' VIRTUAL,
195201
origin_ts TIMESTAMP(3) METADATA FROM 'value.ingestion-timestamp' VIRTUAL,
202+
origin_es TIMESTAMP(3) METADATA FROM 'value.event-timestamp' VIRTUAL,
196203
user_id BIGINT,
197204
item_id BIGINT,
198-
behavior STRING
205+
behavior STRING,
206+
WATERMARK FOR origin_es AS origin_es - INTERVAL '5' SECOND
199207
) WITH (
200208
'connector' = 'kafka',
201209
'topic' = 'user_behavior',

0 commit comments

Comments
 (0)