开发者社区> 问答> 正文

项目里用到了了KafkaTableSourceSinkFactory和JDBCTableSource

黄一刀 2019-11-07 18:22:29 62

项目里用到了了KafkaTableSourceSinkFactory和JDBCTableSourceSinkFactory。maven打包后,META-INF里只会保留第一个 标签的org.apache.flink.table.factories.TableFactory内容。然后执行时就会有找不到合适factory的报错,请问有什么解决办法吗? image.png image.png 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

Java Maven
分享到
取消 提交回答
全部回答(4)
  • 江小白太白
    2019-11-08 19:48:42

    用自定义的tableFactory

    0 0
  • 帅得头晕
    2019-11-07 20:44:37

    connector jar放在flink lib中,不要打进fat

    0 0
  • 黄二刀
    2019-11-07 18:25:44

    修改配置文件 指定parent试试? image.png

    0 0
  • 黄一刀
    2019-11-07 18:24:05

    目前我的解决办法是解压jar,然后修改org.apache.flink.table.factories.TableFactory文件内容,增加需要的org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactory

    0 0
添加回答
阿里云实时计算
使用钉钉扫一扫加入圈子
+ 订阅

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

推荐文章
相似问题
链接