开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

"各位大佬,请教个问题。在用flink1.16.0版本,往lib目录下添加cdc的jar包之后,用s

请问有人用flinkcdc"各位大佬,请教个问题。在用flink1.16.0版本,往lib目录下添加cdc的jar包之后,用sql-client执行测试sql ,会提示缺包,我把jar包查了一下,发现shaded打包方式已经重命名了这些类 9b5a29e6e03984d65c6c52c7d688d619.jpg ec65480ef0b9c2c5675ef1aabdc3225c.jpg 这个问题除了逐个补进去,还有什么好的解决办法吗?目前看这个错误是因为Flink和cdc的connector都使用了shaded插件,对自己所用的依赖进行了重命名。但是不清楚这个对原始包的依赖是哪来的,可能是是写在配置文件里"

同步tidb数据到es吗 ?

展开
收起
十一0204 2023-04-05 08:47:38 195 0
1 条回答
写回答
取消 提交回答
  • 意中人就是我呀!

    为什么你 mysql cdc 的jar 有好几个呢? 只保留sql-connector就行。sql 包含不带sql 的。此回答整理自钉群“Flink CDC 社区”

    2023-04-05 10:34:39
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载