[FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors by ThorneANN · Pull Request #4247 · apache/flink-cdc

ThorneANN · 2026-01-30T04:22:03Z

Function Description: Explain the role and usage scenarios of dynamic table addition.
Version Information: Mark that this feature is supported starting from Flink CDC version 3.1.0.
Usage Example: Provide a complete DataStream API code example.
Operation Steps: Detailedly explain the three-step operation process for enabling and using this feature:
- Step 1: Use savepoint to stop the existing job.
- Step 2: Update the table/collection list configuration.
- Step 3: Restore the job from the savepoint.
API Method: Use .scanNewlyAddedTableEnabled(true) to enable this feature
All documents have referenced the dynamic table-adding document format of the MySQL connector, ensuring consistency in style and structure.

Copilot

Copilot encountered an error and was unable to review this pull request. You can try again by re-requesting a review.

Copilot

Pull request overview

Copilot reviewed 6 out of 6 changed files in this pull request and generated 18 comments.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

Copilot · 2026-01-30T10:38:18Z

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

+      --from-savepoint /tmp/flink-savepoints/savepoint-cca7bc-bb1e257f0dab \
+      ./FlinkCDCExample.jar
+```
+**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.


The phrase "Please refer the doc" is missing the preposition "to". It should be "Please refer to the doc".

Suggested change

**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.

**Note:** Please refer to 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.

Copilot · 2026-01-30T10:38:18Z

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

+   // your business code
+```
+
+If we would like to add new collections `[order, custom]` to an existing Flink job, just need to update the `collectionList()` value of the job to include `[order, custom]` and restore the job from previous savepoint.


This sentence is missing a subject. It should read "we just need to update" instead of "just need to update". The sentence currently reads "If we would like to add new collections... just need to update" which is grammatically incorrect.

Suggested change

If we would like to add new collections `[order, custom]` to an existing Flink job, just need to update the `collectionList()` value of the job to include `[order, custom]` and restore the job from previous savepoint.

If we would like to add new collections `[order, custom]` to an existing Flink job, we just need to update the `collectionList()` value of the job to include `[order, custom]` and restore the job from previous savepoint.

Copilot · 2026-01-30T10:38:19Z

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

+
+**Note:** This feature is available since Flink CDC 3.1.0.
+
+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 binlog automatically.


The description mentions "binlog" which is MySQL-specific terminology. For PostgreSQL, the correct term should be "WAL (Write-Ahead Log)" or "replication slot changes". PostgreSQL doesn't use binlog.

Copilot · 2026-01-30T10:38:19Z

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

+        .tableList("INVENTORY.PRODUCT", "INVENTORY.USER", "INVENTORY.ADDRESS") // set captured tables
+        .username("yourUsername")
+        .password("yourPassword")
+        .scanNewlyAddedTableEnabled(true) // enable scan the newly added tables feature


The comment refers to "scan the newly added tables feature" but should be "scan newly added tables feature" (remove the article "the" before "newly") to be consistent with the section title and standard English usage.

Suggested change

.scanNewlyAddedTableEnabled(true) // enable scan the newly added tables feature

.scanNewlyAddedTableEnabled(true) // enable scan newly added tables feature

Copilot · 2026-01-30T10:38:19Z

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

+   // your business code
+```
+
+If we would like to add new tables `[INVENTORY.ORDER, INVENTORY.CUSTOM]` to an existing Flink job, just need to update the `tableList()` value of the job to include `[INVENTORY.ORDER, INVENTORY.CUSTOM]` and restore the job from previous savepoint.


This sentence is missing a subject. It should read "we just need to update" instead of "just need to update". The sentence currently reads "If we would like to add new tables... just need to update" which is grammatically incorrect.

Suggested change

If we would like to add new tables `[INVENTORY.ORDER, INVENTORY.CUSTOM]` to an existing Flink job, just need to update the `tableList()` value of the job to include `[INVENTORY.ORDER, INVENTORY.CUSTOM]` and restore the job from previous savepoint.

If we would like to add new tables `[INVENTORY.ORDER, INVENTORY.CUSTOM]` to an existing Flink job, we just need to update the `tableList()` value of the job to include `[INVENTORY.ORDER, INVENTORY.CUSTOM]` and restore the job from previous savepoint.

Copilot · 2026-01-30T10:38:22Z

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

+
+**Note:** This feature is available since Flink CDC 3.1.0.
+
+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.


The phrase "for existing running pipeline" is missing an article. It should be "for an existing running pipeline" or "for the existing running pipeline".

Suggested change

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.

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

Copilot · 2026-01-30T10:38:22Z

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

+                .username("yourUsername")
+                .password("yourPassword")
+                .slotName("flink")
+                .scanNewlyAddedTableEnabled(true) // enable scan the newly added tables feature


The comment refers to this as "scan the newly added tables feature" but should be more concise as "scan newly added tables feature" (remove the article "the" before "newly") to match standard English usage and be consistent with the section title.

Suggested change

.scanNewlyAddedTableEnabled(true) // enable scan the newly added tables feature

.scanNewlyAddedTableEnabled(true) // enable scan newly added tables feature

Copilot · 2026-01-30T10:38:22Z

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

+        .collectionList("db.product", "db.user", "db.address") // set captured collections
+        .username("yourUsername")
+        .password("yourPassword")
+        .scanNewlyAddedTableEnabled(true) // enable scan the newly added tables feature


The comment refers to "scan the newly added tables feature" but should be "scan newly added tables feature" (remove the article "the" before "newly") to be consistent with the section title and standard English usage.

Suggested change

.scanNewlyAddedTableEnabled(true) // enable scan the newly added tables feature

.scanNewlyAddedTableEnabled(true) // enable scan newly added tables feature

Copilot · 2026-01-30T10:38:23Z

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

+
+**Note:** This feature is available since Flink CDC 3.1.0.
+
+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 redo log automatically.


The adverb "firstly" should be "first" in standard American English usage. While "firstly" is grammatically correct in British English, the documentation appears to follow American English conventions.

Suggested change

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 redo log automatically.

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 first and then read their redo log automatically.

Copilot · 2026-01-30T10:38:23Z

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

+
+**Note:** This feature is available since Flink CDC 3.1.0.
+
+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 redo log automatically.


The phrase "for existing running pipeline" is missing an article. It should be "for an existing running pipeline" or "for the existing running pipeline".

Suggested change

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 redo log automatically.

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 firstly and then read their redo log automatically.

supple NewlyAddTable's doc with mongodb,postgres,oracle connectors

8b264e7

github-actions bot added the docs Improvements or additions to documentation label Jan 30, 2026

ThorneANN changed the title ~~[Flink-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors~~ [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors Jan 30, 2026

lvyanquan requested a review from Copilot January 30, 2026 08:53

Copilot started reviewing on behalf of lvyanquan January 30, 2026 08:57 View session

Copilot AI reviewed Jan 30, 2026

View reviewed changes

lvyanquan requested a review from Copilot January 30, 2026 10:29

Copilot started reviewing on behalf of lvyanquan January 30, 2026 10:32 View session

Copilot AI reviewed Jan 30, 2026

View reviewed changes

Thorne added 2 commits February 2, 2026 10:43

Fix some grammatical issues

9b5bf80

Fix some grammatical issues -2

40a4242

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors#4247

[FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors#4247
ThorneANN wants to merge 3 commits intoapache:masterfrom
ThorneANN:FLINK-39001-supple-doc-with-newlyaddedtable

ThorneANN commented Jan 30, 2026

Uh oh!

Copilot AI left a comment

Uh oh!

Copilot AI left a comment

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Copilot AI Jan 30, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

1 participant

	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.
	Note: Please refer to 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.

	If we would like to add new collections `[order, custom]` to an existing Flink job, just need to update the `collectionList()` value of the job to include `[order, custom]` and restore the job from previous savepoint.
	If we would like to add new collections `[order, custom]` to an existing Flink job, we just need to update the `collectionList()` value of the job to include `[order, custom]` and restore the job from previous savepoint.


		Note: This feature is available since Flink CDC 3.1.0.

		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 binlog automatically.

	.scanNewlyAddedTableEnabled(true) // enable scan the newly added tables feature
	.scanNewlyAddedTableEnabled(true) // enable scan newly added tables feature

	If we would like to add new tables `[INVENTORY.ORDER, INVENTORY.CUSTOM]` to an existing Flink job, just need to update the `tableList()` value of the job to include `[INVENTORY.ORDER, INVENTORY.CUSTOM]` and restore the job from previous savepoint.
	If we would like to add new tables `[INVENTORY.ORDER, INVENTORY.CUSTOM]` to an existing Flink job, we just need to update the `tableList()` value of the job to include `[INVENTORY.ORDER, INVENTORY.CUSTOM]` and restore the job from previous savepoint.

	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.
	The Scan Newly Added Tables feature enables you to add new collections to monitor for an existing running pipeline. The newly added collections will read their snapshot data firstly and then read their change stream automatically.

Conversation

ThorneANN commented Jan 30, 2026

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Jan 30, 2026

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

1 participant