@JarkWu，你的意思是定义成string，但是输入数据是一个json object也可以支持？这岂不是需要对json部分的反序列化做特殊定制。
比如a字段是string，但数据中a属性是这样的：
"a":{ .. }。在java中相当于需要先将a这部分反序列化为一个map，然后再序列化为json（字符串）后作为a这个string的值。
？是吗。
Jark Wu <[email protected]> 于2020年12月8日周二 下午1:42写道：
> hailong 说的定义成 STRING 是在1.12 版本上支持的，
> https://issues.apache.org/jira/browse/FLINK-18002
>
> 1.12 这两天就会发布，如果能升级的话，可以尝试一下。
>
> Best,
> Jark
>
> On Tue, 8 Dec 2020 at 11:56, wxpcc <[email protected]> wrote:
>
> > 可以使用字符串的方式，或者自定义 String类型format，内部结构再通过udf去做后续的实现
> >
> >
> >
> > --
> > Sent from: http://apache-flink.147419.n8.nabble.com/
>
