问答 iceberg 流式读写遇到的问题

iceberg 流式读写遇到的问题

   shao    发布于 2022-01-21 16:41 最新回复 2022-01-25 16:34  来自于   小刀  602  1

按照 example 里 iceberg 的样例修改如下:

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user67/question/f41744846c9ef24e1d30d4946089b6dc..png
在本地 local 模式做测试时报错如下:

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user67/question/fe1333e366579815c37135e1ed43877a..png

不知该如何解决

希望能帮忙解答一下,感谢

1条回答
小刀
回复于 2022-01-25 16:34

1: 指定的flink lib 目录下需要添加

(1)catalog 相关的包:flink-connector-hive_2.12-1.12.5.jar,hive-exec-2.1.1.jar

(2)iceberg 相关的包:iceberg-flink-runtime-0.12.1.jar

0 0
社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群