开发者社区> 问答> 正文

flink1.4.2 使用kafka08jsontablesource,我们测试,kafka里没有数据的情况下,程序运行一段时间就会报这个exception

转自钉钉群21789141:flink1.4.2 使用kafka08jsontablesource,我们测试,kafka里没有数据的情况下,程序运行一段时间就会报这个exception,
image

flink从1.4.2升级到1.5.3后,报找不到JsonRowSerializationSchema,是不是有些denpendency啊?

展开
收起
赵慧@ApacheFlink中文社区 2018-10-18 14:59:08 3134 0
1 条回答
写回答
取消 提交回答
  • 莱昂:flink-json flink-shaded-jackson 你加上这两个试试

    问:flink-json OK了 多谢你哈

    2019-07-17 23:09:16
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
移动互联网测试到质量的转变 立即下载
给ITer的技术实战进阶课-阿里CIO学院独家教材(四) 立即下载
F2etest — 多浏览器兼容性测试整体解决方案 立即下载