[ https://issues.apache.org/jira/browse/FLINK-25485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Leonard Xu resolved FLINK-25485. -------------------------------- Fix Version/s: 1.16.0 Resolution: Resolved Resolved in master(1.16): 61374638c02e5f996cad678253c99363f7ae01a5 > JDBC connector implicitly append url options when use mysql > ----------------------------------------------------------- > > Key: FLINK-25485 > URL: https://issues.apache.org/jira/browse/FLINK-25485 > Project: Flink > Issue Type: Improvement > Components: Connectors / JDBC > Affects Versions: 1.14.2 > Reporter: Luning Wang > Assignee: Luning Wang > Priority: Major > Labels: pull-request-available, stale-assigned > Fix For: 1.16.0 > > > When we directly use buffer-flush options of the mysql sink > (sink.buffer-flush.max-rows and sink.buffer-flush.interval) can not increase > throughput. > We must set 'rewriteBatchedStatements=true' into mysql jdbc url, for > 'sink.buffer-flush' to take effect. > Such as: 'jdbc:mysql://ip:3306/dbname?rewriteBatchedStatements=true' > I want add a method appendUrlSuffix in MySQLDialect to auto set this jdbc > option. > Many users forget or don't know this option. > Inspired by alibaba DataX. > [https://github.com/alibaba/DataX/blob/master/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DataBaseType.java] -- This message was sent by Atlassian Jira (v8.20.10#820010)