mysql-cdc全量同步阶段能否按照某字段排序读取 #1707
Unanswered
moonService
asked this question in
Q&A
Replies: 2 comments
-
modify ChunkSplitter |
Beta Was this translation helpful? Give feedback.
0 replies
-
A table option is provided in the new version 2.3.0. public static final ConfigOption<String> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN =
ConfigOptions.key("scan.incremental.snapshot.chunk.key-column")
.stringType()
.noDefaultValue()
.withDescription(
"The chunk key of table snapshot, captured tables are split into multiple chunks by a chunk key when read the snapshot of table."
+ "By default, the chunk key is the first column of the primary key."
+ "This column must be a column of the primary key."); |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
rt,在实时计算的过程中需要数据按照顺序进行计算,flinkcdc似乎不支持,我看MySqlSource中没有类似的配置,或者在使用flinkcdc的基础上有什么其他方案。
Beta Was this translation helpful? Give feedback.
All reactions