目前是不支持的。这个需求有点太业务特定了。flink 不可能为了一个错误日志去抽象、对接各种存储系统。
一种方案是社区可以考虑支持下打印到日志里,然后用户可以通过自定义插件 log appender 写入外部存储。

Best,
Jark

On Tue, 21 Jul 2020 at 18:53, Dream-底限 <[email protected]> wrote:

> hi
>  json.ignore-parse-errors那只配置这个就好了, 其实我想把解析失败的数据存储到外部系统,而不是直接丢弃
>
> Leonard Xu <[email protected]> 于2020年7月21日周二 下午4:18写道:
>
> > Hi,
> > 我理解应该做不到,因为这两个format参数在format里就做的。
> > json.ignore-parse-errors 是在
> > format解析时跳过解析失败的数据继续解析下一行,json.fail-on-missing-field
> > 是标记如果字段少时是否失败还是继续(缺少的字段用null补上)
> > 这两个不能同时为ture,语义上就是互斥的。
> >
> > Best
> > Leonard Xu
> > > 在 2020年7月21日,16:08,Dream-底限 <[email protected]> 写道:
> > >
> > >
> >
> json数据,在创建表的时候发现json数据解析的时候有下面两项,这两项如果开启那么解析失败的数据是会被丢掉吗,有没有方式可以把解析失败的数据打到外部存储
> >
> >
>

回复