You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by "Narayanan, Surat" <su...@verizon.com> on 2018/10/29 13:55:44 UTC

Needed more information about jdbc sink in Flink SQL Client

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: ****



Regards,
N.Surat

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

Posted by "Narayanan, Surat" <su...@verizon.com>.
Timo,

It helped, I implemented AppendStream table sink and factory and able to
configure JDBC sink.
Thank you.


Regards,
N.Surat


On Mon, Oct 29, 2018 at 7:47 PM Timo Walther <tw...@apache.org> 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
> <https://urldefense.proofpoint.com/v2/url?u=https-3A__ci.apache.org_projects_flink_flink-2Ddocs-2Drelease-2D1.6_dev_table_connect.html&d=DwMDaQ&c=udBTRvFvXC5Dhqg7UHpJlPps3mZ3LRxpb6__0PomBTQ&r=34b4ezf3dFiQDUb7AcME8ZXIhrmSJT4SF5xe8Q_YMbI&m=UiUdTO-jrXZYMNWUPaJsvJj4vAZUT8YV_OWHJv07rIk&s=WUQsw-NACHIQ6e47av1kWT_rw99yEsuaBCOPu554qtY&e=>
> [2]
> https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html#further-tablesources-and-tablesinks
> <https://urldefense.proofpoint.com/v2/url?u=https-3A__ci.apache.org_projects_flink_flink-2Ddocs-2Drelease-2D1.6_dev_table_connect.html-23further-2Dtablesources-2Dand-2Dtablesinks&d=DwMDaQ&c=udBTRvFvXC5Dhqg7UHpJlPps3mZ3LRxpb6__0PomBTQ&r=34b4ezf3dFiQDUb7AcME8ZXIhrmSJT4SF5xe8Q_YMbI&m=UiUdTO-jrXZYMNWUPaJsvJj4vAZUT8YV_OWHJv07rIk&s=JFsPcoWBS_DGl7HGDzz_3rzuIJWd9hFrFl3GoexlYuM&e=>
> [3]
> https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/sourceSinks.html#define-a-tablefactory
> <https://urldefense.proofpoint.com/v2/url?u=https-3A__ci.apache.org_projects_flink_flink-2Ddocs-2Drelease-2D1.6_dev_table_sourceSinks.html-23define-2Da-2Dtablefactory&d=DwMDaQ&c=udBTRvFvXC5Dhqg7UHpJlPps3mZ3LRxpb6__0PomBTQ&r=34b4ezf3dFiQDUb7AcME8ZXIhrmSJT4SF5xe8Q_YMbI&m=UiUdTO-jrXZYMNWUPaJsvJj4vAZUT8YV_OWHJv07rIk&s=JUtzGKSgRPA0u4oHeZxNPU6AxAeIArDhBh793t4UfXc&e=>
>
> 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
> <https://urldefense.proofpoint.com/v2/url?u=https-3A__ci.apache.org_projects_flink_flink-2Ddocs-2Drelease-2D1.6_dev_table_sqlClient.html&d=DwMDaQ&c=udBTRvFvXC5Dhqg7UHpJlPps3mZ3LRxpb6__0PomBTQ&r=34b4ezf3dFiQDUb7AcME8ZXIhrmSJT4SF5xe8Q_YMbI&m=UiUdTO-jrXZYMNWUPaJsvJj4vAZUT8YV_OWHJv07rIk&s=3UvLGGJ7avB1XQYkx5vmwlNu3-eMo8hg8EfwO0Mftwk&e=>
> 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: ****
>
>
>
> Regards,
> N.Surat
>
>
>

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

Posted by Timo Walther <tw...@apache.org>.
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: ****
>
>
>
> Regards,
> N.Surat