Hi, I tried flink-jdbc [1] to read data from Druid because Druid implements Calcite Avatica [2], but the connection string, jdbc:avatica:remote:url= http://BROKER:8082/druid/v2/sql/avatica/, is not supported by any of JDBCDialects [3].
I implement custom JDBCDialect [4], custom StreamTableSourceFactory [5], etc in my own repository [6], but it seems overkill. How about supporting custom JDBC dialects in flink-jdbc based on SPI? Best, - Dongwon [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connect.html#jdbc-connector [2] https://druid.apache.org/docs/latest/querying/sql.html#jdbc [3] https://github.com/apache/flink/blob/master/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/dialect/JDBCDialects.java [4] https://github.com/eastcirclek/flink-avatica-source/blob/master/src/main/java/io/github/eastcirclek/AvaticaJDBCDialect.java [5] https://github.com/eastcirclek/flink-avatica-source/blob/master/src/main/java/io/github/eastcirclek/AvaticaJDBCSourceFactory.java [6] https://github.com/eastcirclek/flink-avatica-source
