flink报错: Caused by: java.lang.NullPointerException: Assigned key must not be null!
具体如下
原因 keyBy的字段不能为null
M.参考Flink运行出现Assigned key must not be null

flink报错: Caused by: java.lang.NullPointerException: Assigned key must not be null!
具体如下
原因 keyBy的字段不能为null
M.参考Flink运行出现Assigned key must not be null