flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "lucas.wu"<lucas...@xiaoying.com>
Subject 关于task异常的问题
Date Mon, 02 Mar 2020 09:59:47 GMT
Hi 大家好
最近有使用flink自带的jdbc outputformat 将flink处理后的数据写到mysql,但是如果我的数据格式有问题,比如超过mysql对应字段设置的大小,或者数据库出现问题,导致延时。这些问题都会导致这个task抛出异常,导致task
fail,进而导致整个job从checkpoint重启。
我的问题是,如果我使用的是flink提供的outputformat,我是否可以catch 异常,并且忽略。如果没有,有没有其它好的办法?
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message