问答 基于Flinkx写入Iceberg,问下,中间是有用Kafka吗?还是Flinkx裸写?怎么解决小文件问题?

基于Flinkx写入Iceberg,问下,中间是有用Kafka吗?还是Flinkx裸写?怎么解决小文件问题?

   匿名用户    发布于 2022-01-24 09:57 最新回复 2022-01-24 10:01  来自于   群内解答  575  1
1条回答
群内解答
回复于 2022-01-24 10:01



问题解答来源于群友:shihe

ClassCastException: org.apache.flink.table.data.GenericRowData cannot be cast to com.dtstack.flinkx.element.ColumnRowData
Http connector
http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user68/answer/3bd2fbb892b30e88d4fb8acf022a7dd6..png



这里改成rowData就可以了

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user68/answer/f0adbe25387342814fb00dc60f4dfdb8..png

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

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