Flink各种疑难杂症

标签：runtime   apach   copy   match   exce   more   ali   opera   util   

1.

Caused by: java.lang.RuntimeException: Row arity of from does not match serializers.
at org.apache.flink.api.java.typeutils.runtime.RowSerializer.copy(RowSerializer.java:89)
at org.apache.flink.api.java.typeutils.runtime.RowSerializer.copy(RowSerializer.java:47)
at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:577)
... 22 more

这种情况就是你返回的row的类型和配置的输出字段个数不匹配，有可能是你的代码出现了null值。

Flink各种疑难杂症

标签：runtime   apach   copy   match   exce   more   ali   opera   util   

原文地址：https://www.cnblogs.com/javazyh/p/13097825.html