Flink各种疑难杂症

Posted javazyh

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink各种疑难杂症相关的知识，希望对你有一定的参考价值。

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各种疑难杂症的主要内容，如果未能解决你的问题，请参考以下文章

Android专治Activity各种疑难杂症

SQL邮件服务（解决各种疑难杂症）+案例

这篇文章，专治MQ中间件各种疑难杂症

Python安装alipay-sdk提示安装pycrypto各种疑难杂症及解决方案

一文解决Flutter中使用TextField遇到的各种疑难杂症

Python踩坑之路-Python-3.6 安装pycrypto 2.6.1各种疑难杂症及解决方案