Needed more information about jdbc sink in Flink SQL Client

[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.

https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/sqlClient.html

Where can I find the entire definitions for that YAML configuration?

 tables:

  - name: SinkTable

    type: sink

    update-mode: append

    connector:

      type: jdbc

      driverName: org.apache.derby.jdbc.EmbeddedDriver

      dbURL: jdbc:oracle:thin:@host:port/serviceName

      username: dbuser

      password: ****

[Timo Walther]

Hi,

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.

Regards,
Timo


[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.

https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/sqlClient.html

Where can I find the entire definitions for that YAML configuration?

 tables:

  - name: SinkTable

    type: sink

    update-mode: append

    connector:

      type: jdbc

      driverName: org.apache.derby.jdbc.EmbeddedDriver

      dbURL: jdbc:oracle:thin:@host:port/serviceName

      username: dbuser

      password: ****

[Narayanan, Surat]

Timo,

It helped, I implemented AppendStream table sink and factory and able to

configure JDBC sink.

Thank you.

On Mon, Oct 29, 2018 at 7:47 PM Timo Walther <[hidden email]> wrote:

Hi,

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.

Regards,
Timo


[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.

https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/sqlClient.html

Where can I find the entire definitions for that YAML configuration?

 tables:

  - name: SinkTable

    type: sink

    update-mode: append

    connector:

      type: jdbc

      driverName: org.apache.derby.jdbc.EmbeddedDriver

      dbURL: jdbc:oracle:thin:@host:port/serviceName

      username: dbuser

      password: ****