flink-connector-jdbc
flink-connector-jdbc copied to clipboard
apache
Apache flink
https://issues.apache.org/jira/browse/FLINK-33929?filter=-2
related to [FLINK-31530](https://issues.apache.org/jira/browse/FLINK-31530) Implement OracleCatalog for the Oracle dialect
[hotfix] fix the problems with special table name characters of postgres and oracle and sqlserver.
This improvement implements [FLIP-377 Support fine-grained configuration to control filter push down for Table/SQL Sources](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=276105768)
I fixed a corner case out-of-memory error when we use a timed flushing interval, where the scheduler thread could repeatly throw a new RuntimeException wrapping the previous one as cause....
The idea is pretty straightforward: from one side there is a jdbc url which is normally is provided by most of the dbs providers to connect to. From the other...
Mysql and Postgres catalog support url extra parameters CREATE CATALOG mymysql WITH( 'type' = 'jdbc', 'default-database' = 'test', 'username' = 'root', 'password' = 'xxx', 'base-url' = 'jdbc:mysql://xxx:53309', 'extra-url-param' = '?characterEncoding=utf8'...
## What is the purpose of the change Add the implementation of the Vertica dialect ## Brief change log Added: VerticaDialect VerticaDialectFactory VerticaRowConverter ## Verifying this change This change added...
Fix the problem of JdbcOutputFormat database connection leak
- Change the default quote identifier for MS SQL dialect - Change static to cconditional upsert statement in case there are no fields to update
