其实虽然问题解决了，但是具体问题出现的原理并没有整理明白。
目前猜测是null的输出类型对后续的输入类型有影响，但是具体的影响怎么发生，估计得抽空研究源码才能知道了。后续有结果再更
ExceptionInChainedOperatorException：flink写hbase对于null数据导致数据导致出现异常 (3)
内容版权声明：除非注明，否则皆为本站原创文章。
其实虽然问题解决了，但是具体问题出现的原理并没有整理明白。
目前猜测是null的输出类型对后续的输入类型有影响，但是具体的影响怎么发生，估计得抽空研究源码才能知道了。后续有结果再更
内容版权声明：除非注明，否则皆为本站原创文章。