Flink MySQL CDC 表名大小写不敏感? #1857
Unanswered
ElasticForce
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
mysql cdc version: flink-connector-mysql-cdc:2.3.0
flink version: 1.14.3
mysql: 5.7
数据库里有两张表,mysql_case1和MYSQL_CASE1,想要抽小写表名的数据,但是两张表的数据都抽了出来
MySqlSource mySqlSource = MySqlSource.builder()
.hostname("x.x.x.x")
.port(3306)
.databaseList("flinkcdc")
.tableList("flinkcdc.mysql_case1")
.username("username")
.password("password")
.deserializer(new JsonDebeziumDeserializationSchema())
.includeSchemaChanges(true)
.build();
Beta Was this translation helpful? Give feedback.
All reactions