【Flink】报错 Could not forward element to next operator,null pointer Exception.-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

【Flink】报错 Could not forward element to next operator,null pointer Exception.

2018-11-15 12:58:00 18338 1

错误描述
【上线报错】:Could not forward element to next operator,null pointer Exception.
22
报错原因
这个异常一般是数据源端,出现脏数据,存在null值导致的。

取消 提交回答
全部回答(1)
  • 李博 bluemind
    2019-07-17 23:14:27

    报错原因
    这个异常一般是数据源端,出现脏数据,存在null值导致的。

    解决方案
    一般是Watermark里的Event time的时间字段里有NULL值,您可以用如下计算列来把null值过滤。

    ts as case when datetime is null

           then timestamp '1970-01-01 00:00:00' 
           else `datetime` end
    2 0
相关问答

0

回答

这个『根据 op 值判断操作类型来自己组装 sql』是指在哪里实现?是指单纯用 Flink Tabl

2022-06-29 15:11:43 84浏览量 回答数 0

1

回答

Blink任务报错Slot allocation request timed out for xxx

2021-10-22 10:18:39 566浏览量 回答数 1

1

回答

Flink 如何实现 Checkpoint 的 EXACTLY_ONCE 语义

2021-01-05 23:23:15 865浏览量 回答数 1

1

回答

python tkinter中想打开一个.txt文件并显示在text中?报错

2020-06-14 15:52:07 550浏览量 回答数 1

1

回答

遇到No declaration for function xxx怎么解决?c报错

2020-05-29 11:00:33 224浏览量 回答数 1

1

回答

datenode日志:error processing read_block operation

2020-05-16 13:20:14 331浏览量 回答数 1

1

回答

【Flink】报错 Failed to encode 'xxxx' in character set 'ISO-8859-1'

2018-11-15 12:05:09 4146浏览量 回答数 1

1

回答

【Flink】报错 Slot allocation request timed out for

2018-11-15 15:13:46 2636浏览量 回答数 1

1

回答

tomcat 启动报错error in opening zip file,什么原因?

2016-06-03 15:08:52 13360浏览量 回答数 1

2

回答

ECS装ORACLE的问题

2014-10-08 10:56:19 6156浏览量 回答数 2
+关注
李博 bluemind
云栖社区Java、Redis、MongoDB运营小编,有意合作请联系钉钉:15810436147
2107
文章
1103
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载