Apache Beam管道Dataflow运行正常 用Flink Runner报Cannot union streams of different types错误

这个报错并非由Flink暂不支持的Beam特性导致，核心原因是Flink Runner与Dataflow Runner的Union操作类型校验严格度不同。

• Dataflow Runner在执行时会自动兼容处理部分隐式的PCollection类型差异，比如字段顺序、Nullable属性不完全匹配的同类结构集合，不会触发类型报错。
• Flink Runner对Union操作的输入有强制校验要求：所有参与合并的PCollection的Coder类型必须完全一致，包括泛型参数、字段序列化规则、Nullable配置等任意项存在差异时，都会抛出你遇到的Cannot union streams of different types错误。

你可以从以下几个方向排查调整：

• 逐一核对所有参与Union操作的PCollection的输出类型声明，排查是否存在隐式类型转换，比如部分分支输出TableRow、部分分支输出自定义实体类，或是同类结构的Coder配置在不同分支存在差异。
• 显式调用setCoder()方法为所有参与Union的PCollection指定同一个Coder实例，强制统一序列化规则，规避Beam自动类型推断的偏差。
• 检查是否存在多输出转换（如ParDo输出PCollectionTuple）的类型声明缺失，这类场景下Beam的自动类型推断在Flink Runner中容易失效，需要手动指定输出类型的Coder。

内容的提问来源于stack exchange，提问作者Joseph D