[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Needed more information about jdbc sink in Flink SQL Client


all supported connectors and formats for the SQL Client with YAML can be found in the connect section [1]. However, the JDBC sink is not available for the SQL Client so far. It still needs to be ported, see [2].

However, if you want to use it. You could implement your own table factory that creates an instance of the sink. This is documented here [3].

I hope this helps.


[1] https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html
[2] https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html#further-tablesources-and-tablesinks
[3] https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/sourceSinks.html#define-a-tablefactory

Am 29.10.18 um 14:55 schrieb Narayanan, Surat:
Flink team,

I am exploring the Flink SQL client and trying to configure JDBC Sink in YAML
I only find some sample YAML configuration in the documentation.
Where can I find the entire definitions for that YAML configuration?

  - name: SinkTable
    type: sink
    update-mode: append
      type: jdbc
      driverName: org.apache.derby.jdbc.EmbeddedDriver
      dbURL: jdbc:oracle:thin:@host:port/serviceName
      username: dbuser
      password: ****