Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -308,6 +308,9 @@ Limitation
--------

### Can't perform checkpoint during scanning snapshot of tables

*注意:此限制仅在未启用增量快照框架(即 `scan.incremental.snapshot.enabled` 设置为 `false`)时适用。*

During scanning snapshot of database tables, since there is no recoverable position, we can't perform checkpoints. In order to not perform checkpoints, SqlServer CDC source will keep the checkpoint waiting to timeout. The timeout checkpoint will be recognized as failed checkpoint, by default, this will trigger a failover for the Flink job. So if the database table is large, it is recommended to add following Flink configurations to avoid failover because of the timeout checkpoints:

```
Expand Down Expand Up @@ -530,8 +533,8 @@ Data Type Mapping
<td>DECIMAL(p, s)</td>
</tr>
<tr>
<td>numeric</td>
<td>NUMERIC</td>
<td>numeric(p, s)</td>
<td>DECIMAL(p, s)</td>
</tr>
<tr>
<td>
Expand Down
7 changes: 5 additions & 2 deletions docs/content/docs/connectors/flink-sources/sqlserver-cdc.md
Original file line number Diff line number Diff line change
Expand Up @@ -308,6 +308,9 @@ Limitation
--------

### Can't perform checkpoint during scanning snapshot of tables

*Note: This limitation only applies when the incremental snapshot framework is not enabled (i.e., `scan.incremental.snapshot.enabled` is set to `false`).*

During scanning snapshot of database tables, since there is no recoverable position, we can't perform checkpoints. In order to not perform checkpoints, SqlServer CDC source will keep the checkpoint waiting to timeout. The timeout checkpoint will be recognized as failed checkpoint, by default, this will trigger a failover for the Flink job. So if the database table is large, it is recommended to add following Flink configurations to avoid failover because of the timeout checkpoints:

```
Expand Down Expand Up @@ -529,8 +532,8 @@ Data Type Mapping
<td>DECIMAL(p, s)</td>
</tr>
<tr>
<td>numeric</td>
<td>NUMERIC</td>
<td>numeric(p, s)</td>
<td>DECIMAL(p, s)</td>
</tr>
<tr>
<td>
Expand Down