Skip to content

Commit 99b7ebb

Browse files
committed
Fix link address errors in documents
Signed-off-by: Pei Yu <125331682@qq.com>
1 parent 13cd198 commit 99b7ebb

14 files changed

Lines changed: 34 additions & 34 deletions

File tree

docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,7 @@ MongoDB 的更改事件记录在消息之前没有更新。因此,我们只能
238238
<td>String</td>
239239
<td> MongoDB CDC 消费者可选的启动模式,
240240
合法的模式为 "initial","latest-offset" 和 "timestamp"。
241-
请查阅 <a href="#a-name-id-002-a">启动模式</a> 章节了解更多详细信息。</td>
241+
请查阅 <a href="#启动模式">启动模式</a> 章节了解更多详细信息。</td>
242242
</tr>
243243
<tr>
244244
<td>scan.startup.timestamp-millis</td>
@@ -423,7 +423,7 @@ CREATE TABLE products (
423423

424424
MongoDB CDC 连接器是一个 Flink Source 连接器,它将首先读取数据库快照,然后在处理**甚至失败时继续读取带有**的更改流事件。
425425

426-
### 启动模式<a name="启动模式" id="002" ></a>
426+
### 启动模式
427427

428428
配置选项```scan.startup.mode```指定 MongoDB CDC 消费者的启动模式。有效枚举包括:
429429

@@ -544,7 +544,7 @@ $ ./bin/flink run \
544544
--from-savepoint /tmp/flink-savepoints/savepoint-cca7bc-bb1e257f0dab \
545545
./FlinkCDCExample.jar
546546
```
547-
**注意:** 请参考文档 [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/cli/#command-line-interface) 了解更多详细信息。
547+
**注意:** 请参考文档 [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/deployment/cli/#command-line-interface) 了解更多详细信息。
548548
549549
### DataStream Source
550550
@@ -694,7 +694,7 @@ CREATE TABLE mongodb_source (...) WITH (
694694
----------------
695695
[BSON](https://docs.mongodb.com/manual/reference/bson-types/) **二进制 JSON**的缩写是一种类似 JSON 格式的二进制编码序列,用于在 MongoDB 中存储文档和进行远程过程调用。
696696
697-
[Flink SQL Data Type](https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/types/) 类似于 SQL 标准的数据类型术语,该术语描述了表生态系统中值的逻辑类型。它可以用于声明操作的输入和/或输出类型。
697+
[Flink SQL Data Type](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/table/types/) 类似于 SQL 标准的数据类型术语,该术语描述了表生态系统中值的逻辑类型。它可以用于声明操作的输入和/或输出类型。
698698
699699
为了使 Flink SQL 能够处理来自异构数据源的数据,异构数据源的数据类型需要统一转换为 Flink SQL 数据类型。
700700
@@ -812,6 +812,6 @@ CREATE TABLE mongodb_source (...) WITH (
812812
- [Replica set protocol](https://docs.mongodb.com/manual/reference/replica-configuration/#mongodb-rsconf-rsconf.protocolVersion)
813813
- [Connection String Options](https://docs.mongodb.com/manual/reference/connection-string/#std-label-connections-connection-options)
814814
- [BSON Types](https://docs.mongodb.com/manual/reference/bson-types/)
815-
- [Flink DataTypes](https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/types/)
815+
- [Flink DataTypes](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/table/types/)
816816
817817
{{< top >}}

docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ mysql> FLUSH PRIVILEGES;
109109
### 为每个 Reader 设置不同的 Server id
110110

111111
每个用于读取 binlog 的 MySQL 数据库客户端都应该有一个唯一的 id,称为 Server id。 MySQL 服务器将使用此 id 来维护网络连接和 binlog 位置。 因此,如果不同的作业共享相同的 Server id, 则可能导致从错误的 binlog 位置读取数据。
112-
因此,建议通过为每个 Reader 设置不同的 Server id [SQL Hints](https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/hints.html),
112+
因此,建议通过为每个 Reader 设置不同的 Server id [SQL Hints](https://nightlies.apache.org/flink/flink-docs-release-2.2/zh/docs/dev/table/sql/queries/hints/),
113113
假设 Source 并行度为 4, 我们可以使用 `SELECT * FROM source_table /*+ OPTIONS('server-id'='5401-5404') */ ;` 来为 4 个 Source readers 中的每一个分配唯一的 Server id。
114114

115115

@@ -246,7 +246,7 @@ Flink SQL> SELECT * FROM orders;
246246
(3)在快照读取之前,Source 不需要数据库锁权限。
247247
如果希望 Source 并行运行,则每个并行 Readers 都应该具有唯一的 Server id,所以
248248
Server id 必须是类似 `5400-6400` 的范围,并且该范围必须大于并行度。
249-
请查阅 <a href="#a-name-id-001-a">增量快照读取</a> 章节了解更多详细信息。
249+
请查阅 <a href="#增量快照读取">增量快照读取</a> 章节了解更多详细信息。
250250
</td>
251251
</tr>
252252
<tr>
@@ -281,7 +281,7 @@ Flink SQL> SELECT * FROM orders;
281281
<td>String</td>
282282
<td> MySQL CDC 消费者可选的启动模式,
283283
合法的模式为 "initial","earliest-offset","latest-offset","specific-offset","timestamp" 和 "snapshot"。
284-
请查阅 <a href="#a-name-id-002-a">启动模式</a> 章节了解更多详细信息。</td>
284+
请查阅 <a href="#启动模式">启动模式</a> 章节了解更多详细信息。</td>
285285
</tr>
286286
<tr>
287287
<td>scan.startup.specific-offset.file</td>
@@ -578,7 +578,7 @@ CREATE TABLE products (
578578
支持的特性
579579
--------
580580

581-
### 增量快照读取<a name="增量快照读取" id="001" ></a>
581+
### 增量快照读取
582582

583583
增量快照读取是一种读取表快照的新机制。与旧的快照机制相比,增量快照具有许多优点,包括:
584584
* (1)在快照读取期间,Source 支持并发读取,
@@ -637,7 +637,7 @@ MySQL 集群中你监控的服务器出现故障后, 你只需将受监视的服
637637
当 MySQL CDC Source 启动时,它并行读取表的快照,然后以单并行度的方式读取表的 binlog。
638638

639639
在快照阶段,快照会根据表的分块键和表行的大小切割成多个快照块。
640-
快照块被分配给多个快照读取器。每个快照读取器使用 [区块读取算法](#snapshot-chunk-reading) 并将读取的数据发送到下游。
640+
快照块被分配给多个快照读取器。每个快照读取器使用 [区块读取算法](#区块读取算法) 并将读取的数据发送到下游。
641641
Source 会管理块的进程状态(完成或未完成),因此快照阶段的 Source 可以支持块级别的 checkpoint。
642642
如果发生故障,可以恢复 Source 并继续从最后完成的块中读取块。
643643

@@ -678,7 +678,7 @@ MySQL CDC Source 使用主键列将表划分为多个分片(chunk)。 默认
678678
[uuid-def, +∞).
679679
```
680680

681-
##### Chunk 读取算法
681+
##### 区块读取算法
682682

683683
对于上面的示例`MyTable`,如果 MySQL CDC Source 并行度设置为 4,MySQL CDC Source 将在每一个 executes 运行 4 个 Readers **通过偏移信号算法**
684684
获取快照区块的最终一致输出。 **偏移信号算法**简单描述如下:
@@ -699,7 +699,7 @@ MySQL CDC Source 使用主键列将表划分为多个分片(chunk)。 默认
699699
MySQL CDC 连接器是一个 Flink Source 连接器,它将首先读取表快照块,然后继续读取 binlog,
700700
无论是在快照阶段还是读取 binlog 阶段,MySQL CDC 连接器都会在处理时**准确读取数据**,即使任务出现了故障。
701701

702-
### 启动模式<a name="启动模式" id="002" ></a>
702+
### 启动模式
703703

704704
配置选项```scan.startup.mode```指定 MySQL CDC 使用者的启动模式。有效枚举包括:
705705

@@ -837,7 +837,7 @@ $ ./bin/flink run \
837837
--from-savepoint /tmp/flink-savepoints/savepoint-cca7bc-bb1e257f0dab \
838838
./FlinkCDCExample.jar
839839
```
840-
**注意:** 请参考文档 [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/cli/#command-line-interface) 了解更多详细信息。
840+
**注意:** 请参考文档 [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/deployment/cli/#command-line-interface) 了解更多详细信息。
841841

842842
### 关于无主键表
843843

@@ -1136,14 +1136,14 @@ $ ./bin/flink run \
11361136
</td>
11371137
<td>
11381138
MySQL 中的空间数据类型将转换为具有固定 Json 格式的字符串。
1139-
请参考 MySQL <a href="#a-name-id-003-a">空间数据类型映射</a> 章节了解更多详细信息。
1139+
请参考 MySQL <a href="#空间数据类型映射">空间数据类型映射</a> 章节了解更多详细信息。
11401140
</td>
11411141
</tr>
11421142
</tbody>
11431143
</table>
11441144
</div>
11451145

1146-
### 空间数据类型映射<a name="空间数据类型映射" id="003"></a>
1146+
### 空间数据类型映射
11471147

11481148
MySQL中除`GEOMETRYCOLLECTION`之外的空间数据类型都会转换为 Json 字符串,格式固定,如:<br>
11491149
```json

docs/content.zh/docs/connectors/flink-sources/oceanbase-cdc.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -831,14 +831,14 @@ CREATE TABLE products (
831831
</td>
832832
<td>
833833
空间数据类型将转换为具有固定 Json 格式的字符串。
834-
请参考 <a href="#a-name-id-003-a">空间数据类型映射</a> 章节了解更多详细信息。
834+
请参考 <a href="#空间数据类型映射">空间数据类型映射</a> 章节了解更多详细信息。
835835
</td>
836836
</tr>
837837
</tbody>
838838
</table>
839839
</div>
840840

841-
### 空间数据类型映射<a name="空间数据类型映射" id="003"></a>
841+
### 空间数据类型映射
842842

843843
`GEOMETRYCOLLECTION`之外的空间数据类型都会转换为 Json 字符串,格式固定,如:<br>
844844
```json

docs/content.zh/docs/connectors/flink-sources/oracle-cdc.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -617,7 +617,7 @@ $ ./bin/flink run \
617617
--from-savepoint /tmp/flink-savepoints/savepoint-cca7bc-bb1e257f0dab \
618618
./FlinkCDCExample.jar
619619
```
620-
**注意:** 请参考文档 [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/cli/#command-line-interface) 了解更多详细信息。
620+
**注意:** 请参考文档 [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/deployment/cli/#command-line-interface) 了解更多详细信息。
621621
622622
### DataStream Source
623623

docs/content.zh/docs/connectors/flink-sources/postgres-cdc.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -222,7 +222,7 @@ Connector Options
222222
(1) source can be parallel during snapshot reading,
223223
(2) source can perform checkpoints in the chunk granularity during snapshot reading,
224224
(3) source doesn't need to acquire global read lock (FLUSH TABLES WITH READ LOCK) before snapshot reading.
225-
Please see <a href="#incremental-snapshot-reading ">Incremental Snapshot Reading</a>section for more detailed information.
225+
Please see <a href="#incremental-snapshot-reading-experimental ">Incremental Snapshot Reading</a>section for more detailed information.
226226
</td>
227227
</tr>
228228
<tr>
@@ -573,7 +573,7 @@ $ ./bin/flink run \
573573
--from-savepoint /tmp/flink-savepoints/savepoint-cca7bc-bb1e257f0dab \
574574
./FlinkCDCExample.jar
575575
```
576-
**注意:** 请参考文档 [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/cli/#command-line-interface) 了解更多详细信息。
576+
**注意:** 请参考文档 [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/deployment/cli/#command-line-interface) 了解更多详细信息。
577577

578578
### DataStream Source
579579

docs/content.zh/docs/connectors/pipeline-connectors/mysql.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -656,7 +656,7 @@ source:
656656
</td>
657657
<td>
658658
MySQL 中的空间数据类型将转换为具有固定 Json 格式的字符串。
659-
请参考 MySQL <a href="#a-name-id-003-a">空间数据类型映射</a> 章节了解更多详细信息。
659+
请参考 MySQL <a href="#空间数据类型映射">空间数据类型映射</a> 章节了解更多详细信息。
660660
</td>
661661
</tr>
662662
</tbody>

docs/content.zh/docs/core-concept/data-pipeline.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ under the License.
3232
为了描述 Data Pipeline,我们需要定义以下部分:
3333
- [source]({{< ref "docs/core-concept/data-source" >}})
3434
- [sink]({{< ref "docs/core-concept/data-sink" >}})
35-
- [pipeline](#pipeline-configurations)
35+
- [pipeline](#pipeline-配置)
3636

3737
下面 是 Data Pipeline 的一些可选配置:
3838
- [route]({{< ref "docs/core-concept/route" >}})

docs/content.zh/docs/core-concept/schema-evolution.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ pipeline:
6868

6969
这是默认的架构演变行为。
7070

71-
> 注意:在此模式下,`TruncateTableEvent` 和 `DropTableEvent` 默认不会被发送到下游,以避免意外的数据丢失。这一行为可以通过配置 [Per-Event Type Control](#per-event-type-control) 调整。
71+
> 注意:在此模式下,`TruncateTableEvent` 和 `DropTableEvent` 默认不会被发送到下游,以避免意外的数据丢失。这一行为可以通过配置 [按类型配置行为](#按类型配置行为) 调整。
7272

7373
### Ignore 模式
7474

docs/content.zh/docs/core-concept/transform.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -496,7 +496,7 @@ pipeline:
496496
```
497497
注意:
498498
* `model-name` 是一个通用的必填参数,用于所有支持的模型,表示在 `projection` 或 `filter` 中调用的函数名称。
499-
* `class-name` 是一个通用的必填参数,用于所有支持的模型,可用值可以在[所有支持的模型](#all-support-models)中找到。
499+
* `class-name` 是一个通用的必填参数,用于所有支持的模型,可用值可以在[所有支持的模型](#所有支持的模型)中找到。
500500
* `openai.model`,`openai.host`,`openai.apiKey` 和 `openai.chat.prompt` 是在各个模型中特别的可选参数。
501501

502502
如何使用一个 Embedding AI 模型:

docs/content/docs/connectors/flink-sources/mongodb-cdc.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -567,7 +567,7 @@ $ ./bin/flink run \
567567
--from-savepoint /tmp/flink-savepoints/savepoint-cca7bc-bb1e257f0dab \
568568
./FlinkCDCExample.jar
569569
```
570-
**Note:** Please refer the doc [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/cli/#command-line-interface) for more details.
570+
**Note:** Please refer the doc [Restore the job from previous savepoint](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/deployment/cli/#command-line-interface) for more details.
571571

572572
### DataStream Source
573573

@@ -714,7 +714,7 @@ Data Type Mapping
714714
----------------
715715
[BSON](https://docs.mongodb.com/manual/reference/bson-types/) short for **Binary JSON** is a binary-encoded serialization of JSON-like format used to store documents and make remote procedure calls in MongoDB.
716716

717-
[Flink SQL Data Type](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/types/) is similar to the SQL standard’s data type terminology which describes the logical type of a value in the table ecosystem. It can be used to declare input and/or output types of operations.
717+
[Flink SQL Data Type](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/table/types/) is similar to the SQL standard’s data type terminology which describes the logical type of a value in the table ecosystem. It can be used to declare input and/or output types of operations.
718718

719719
In order to enable Flink SQL to process data from heterogeneous data sources, the data types of heterogeneous data sources need to be uniformly converted to Flink SQL data types.
720720

@@ -835,6 +835,6 @@ Reference
835835
- [Connection String Options](https://docs.mongodb.com/manual/reference/connection-string/#std-label-connections-connection-options)
836836
- [Document Pre- and Post-Images](https://www.mongodb.com/docs/v6.0/changeStreams/#change-streams-with-document-pre--and-post-images)
837837
- [BSON Types](https://docs.mongodb.com/manual/reference/bson-types/)
838-
- [Flink DataTypes](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/types/)
838+
- [Flink DataTypes](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/table/types/)
839839

840840
{{< top >}}

0 commit comments

Comments
 (0)