Snowflake access through JDBC

Posted by Abhishek Rai on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Snowflake-access-through-JDBC-tp40222.html

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 read a Snowflake table through Flink.

Is there any way to work around this?

```
java.lang.IllegalStateException: Cannot handle such jdbc url:
jdbc:snowflake://abc123.us-east-1.snowflakecomputing.com/?db=TEST
  at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195)
  at org.apache.flink.table.descriptors.JdbcValidator.validateCommonProperties(JdbcValidator.java:79)
  at org.apache.flink.table.descriptors.JdbcValidator.validate(JdbcValidator.java:64)
  at org.apache.flink.connector.jdbc.table.JdbcTableSourceSinkFactory.getValidatedProperties(JdbcTableSourceSinkFactory.java:173)
  at org.apache.flink.connector.jdbc.table.JdbcTableSourceSinkFactory.createStreamTableSource(JdbcTableSourceSinkFactory.java:138)
```

Thanks,
Abhishek