这个得靠你自己打日志吧,在可能出NPE的地方 try catch 到,然后打印原始记录。
小昌同学 <ccc0606fight...@163.com> 于2023年5月29日周一 18:30写道: > > 你好,数据源是kafka,使用的是stream api > > > | | > 小昌同学 > | > | > ccc0606fight...@163.com > | > ---- 回复的原邮件 ---- > | 发件人 | Weihua Hu<huweihua....@gmail.com> | > | 发送日期 | 2023年5月29日 15:29 | > | 收件人 | <user-zh@flink.apache.org> | > | 主题 | Re: flink 输出异常数据 | > Hi, > > 你使用的数据源是什么呢?Kafka 吗?用的是 FlinkSQL 还是 DataStream API 呢? > > 方便把异常栈贴一下吗 > > Best, > Weihua > > > On Mon, May 29, 2023 at 1:36 PM 小昌同学 <ccc0606fight...@163.com> wrote: > > > 各位老师,我有一个作业运行很久了,但是最近源系统有一些脏数据导致作业运行失败,看yarn的日志报错是空指针,但是我现在想把那一条脏数据捕获到,请问一下有啥办法吗?谢谢各位老师的指导 > > > | | > 小昌同学 > | > | > ccc0606fight...@163.com > |