声明可以尝试加上 not null,避免变为 union类型
如: 
headers map<string not null,String not null> not null,
`body` String not null



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复