回复： flink 输出异常数据

Mon, 29 May 2023 03:30:59 -0700 

你好，数据源是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
|

回复