-
如题,从源码的注释上看,earliest模式是全部读binlog,而对initial模式的描述并没有说明snapshot部分是怎么拉取的,是走的jdbc吗 |
Beta Was this translation helpful? Give feedback.
Answered by
SML0127
Sep 2, 2023
Replies: 1 comment 1 reply
-
In initial mode, flink cdc use incremental snapshot. An incremental snapshot divides the table into chunks, and fetches the data from the table on a chunk-by-chunk. During this process, a JDBC connection is created. A JDBC connection is created before fetching a chunk, and the JDBC connection is released when the task of fetching the chunk is finished. You can see this in MySqlSplitReader.java Have a nice day😄😄 |
Beta Was this translation helpful? Give feedback.
1 reply
Answer selected by
wloverine
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
In initial mode, flink cdc use incremental snapshot.
An incremental snapshot divides the table into chunks, and fetches the data from the table on a chunk-by-chunk.
During this process, a JDBC connection is created.
A JDBC connection is created before fetching a chunk, and the JDBC connection is released when the task of fetching the chunk is finished.
You can see this in MySqlSplitReader.java
Have a nice day😄😄