开发者社区> 问答> 正文

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 3205 0
1 条回答
写回答
取消 提交回答
  • 莱昂:flink-json flink-shaded-jackson 你加上这两个试试

    问:flink-json OK了 多谢你哈

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

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载