Ada Wong created FLINK-25485:
--------------------------------
Summary: JDBC connector implicitly add 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: Ada Wong
When we directly use mysql sink, buffer-flush
options(sink.buffer-flush.max-rows, sink.buffer-flush.interval) can not
increase throughput.
We must set 'rewriteBatchedStatements=true' into mysql jdbc url, for
'sink.buffer-flush' to take effect.
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.1#820001)
