Skip to content

Commit 6607efd

Browse files
committed
fix done
1 parent 40a4242 commit 6607efd

3 files changed

Lines changed: 5 additions & 5 deletions

File tree

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -512,11 +512,11 @@ Applications can use change streams to subscribe to all data changes on a single
512512
By the way, Debezium's MongoDB change streams exploration mentioned by [DBZ-435](https://issues.redhat.com/browse/DBZ-435) is on roadmap.<br>
513513
If it's done, we can consider integrating two kinds of source connector for users to choose.
514514

515-
### Scan Newly Added Tables
515+
### Scan Newly Added Collections
516516

517517
**Note:** This feature is available since Flink CDC 3.1.0.
518518

519-
The Scan Newly Added Tables feature enables you to add new collections to monitor for existing running pipeline. The newly added collections will read their snapshot data firstly and then read their change stream automatically.
519+
The Scan Newly Added Collections feature enables you to add new collections to monitor for existing running pipeline. The newly added collections will read their snapshot data firstly and then read their change stream automatically.
520520

521521
Imagine this scenario: At the beginning, a Flink job monitors collections `[product, user, address]`, but after some days we would like the job can also monitor collections `[order, custom]` which contain history data, and we need the job can still reuse existing state of the job. This feature can resolve this case gracefully.
522522

@@ -529,7 +529,7 @@ The following operations show how to enable this feature to resolve above scenar
529529
.collectionList("db.product", "db.user", "db.address") // set captured collections
530530
.username("yourUsername")
531531
.password("yourPassword")
532-
.scanNewlyAddedTableEnabled(true) // enable scan the newly added tables feature
532+
.scanNewlyAddedTableEnabled(true) // enable scan the newly added collections feature
533533
.deserializer(new JsonDebeziumDeserializationSchema()) // converts SourceRecord to JSON String
534534
.build();
535535
// your business code

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -565,7 +565,7 @@ The Oracle CDC source can't work in parallel reading, because there is only one
565565
566566
Scan Newly Added Tables feature enables you to add new tables to monitor for an existing running pipeline. The newly added tables will read their snapshot data first and then read their redo log automatically.
567567
568-
Imagine this scenario: At the beginning, a Flink job monitors tables `[product, user, address]`, but after some days we would like the job can also monitor tables `[order, custom]` which contain history data, and we need the job can still reuse existing state of the job. This feature can resolve this case gracefully.
568+
Imagine this scenario: At the beginning, a Flink job monitors tables `[product, user, address]`, but after some days we would like the job to also monitor tables `[order, custom]` which contain historical data, and we need the job to still reuse existing state of the job. This feature can resolve this case gracefully.
569569
570570
The following operations show how to enable this feature to resolve above scenario. An existing Flink job which uses Oracle CDC Source like:
571571

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -517,7 +517,7 @@ The config option `scan.startup.mode` specifies the startup mode for PostgreSQL
517517

518518
Scan Newly Added Tables feature enables you to add new tables to monitor for existing running pipeline. The newly added tables will read their snapshot data firstly and then read their WAL (Write-Ahead Log) or replication slot changes automatically.
519519

520-
Imagine this scenario: At the beginning, a Flink job monitors tables `[product, user, address]`, but after some days we would like the job can also monitor tables `[order, custom]` which contain history data, and we need the job can still reuse existing state of the job. This feature can resolve this case gracefully.
520+
Imagine this scenario: At the beginning, a Flink job monitors tables `[product, user, address]`, but after some days we would like the job to also monitor tables `[order, custom]` which contain historical data, and we need the job to still reuse existing state of the job. This feature can resolve this case gracefully.
521521

522522
The following operations show how to enable this feature to resolve above scenario. An existing Flink job which uses PostgreSQL CDC Source like:
523523

0 commit comments

Comments
 (0)