flink-connector-jdbc
flink-connector-jdbc copied to clipboard
apache
Apache flink
1. the clickhouse in batch mode ,as sink and source 2. the clickhouse in streaming mode ,as sink
When there is a conflict between a field name and a keyword in a PostgreSQL table, it is necessary to use quotation marks
Remove redundant maven properties with upgrade of flink-connector-parent to 1.1.0
An SQL Server sink connector may fail with the following exception: ``` java.io.IOException: Writing records to JDBC failed. at org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.writeRecord(JdbcOutputFormat.java:198) at org.apache.flink.connector.jdbc.internal.GenericJdbcSinkFunction.invoke(GenericJdbcSinkFunction.java:57) at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:54) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:68) at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:62)...
Bump flink version to 1.20.0 for preparing lineage integration.
The PR adds Elasticsearch dialect. Important facts: * `x-pack-sql-jdbc` dependency is on Elastic license which is not compatible with Apache license. Therefore: * `x-pack-sql-jdbc` has `provided` scope. * appropriate note...
When using PostgreSQL JDBC Catalog an error is thrown if any of the tables has column of type `json` or `jsonb`. ``` java.lang.UnsupportedOperationException: Doesn't support Postgres type 'jsonb' yet ```...
fixes [FLINK-36303](https://issues.apache.org/jira/browse/FLINK-36303)
- Created the module flink-connector-jdbc-architecture to have all tests, we need to add the modules as dependency to validate that module.. - Created the package "org.apache.flink.connector.jdbc.core.util" to have classes of...
