Thanks Roman, I ended up switching to the DataStream API and using
JdbcInputFormat like you suggested and that worked out fine. Thanks!
On Fri, Dec 18, 2020 at 10:21 AM Khachatryan Roman
wrote:
>
> Hello,
>
> Unfortunately, this driver is not currently supported by the Table API [1].
> You can i
Hello,
Unfortunately, this driver is not currently supported by the Table API [1].
You can implement a dialect for it [2] and construct JdbcTableSource [3]
manually.
Alternatively, you can switch to the DataStream API and use JdbcInputFormat
[4] which doesn't require dialect.
I'm also pulling in
Hello,
I'm trying to create a `StreamTableSource` for Snowflake using
`JdbcTableSourceSinkFactory.createStreamTableSource` (in package
org.apache.flink.connector.jdbc.table) but it fails with the following
error message due to `JdbcDialects` not having a dialect for
Snowflake.
My goal is to fully
