关于jdbc connector扩展问题
hi all我这里有个需求需要从sql里面写数据到clickhouse里面，但是看源码，发现并不好扩展，https://github.com/apache/flink/blob/d04872d2c6b7570ea3ba02f8fc4fca02daa96118/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialects.java#L30, 这里我看直接写死仅支持DerbyDialect、MySQLDialect、PostgresDialect，而且这个类不支持注册jdbc新驱动，如果想在SQL里面支持其他类型的数据库的话，该怎么弄，求支招
*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
目前 flink-connector-jdbc 还不支持注册
dialect，社区有这方面的计划，但是目前还没有资源做这一块，这是个比较复杂的功能，需要对接口做细致的设计。
目前你可以拿 flink-connector-jdbc 源码，加一个自己的 Dialect 类，在 JdbcDialects 中注册进你的
dialect，然后编译打包就可以了。
*来自志愿者整理的flink邮件归档
2021-12-06 17:03:15赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
