org.apache.flink.compiler.plan.PlanNode to org.apache.flink.compiler.plan.BinaryUnionPlanNode