Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/6267#discussion_r200478336 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetUnion.scala --- @@ -36,22 +39,21 @@ import scala.collection.JavaConverters._ class DataSetUnion( cluster: RelOptCluster, traitSet: RelTraitSet, - leftNode: RelNode, - rightNode: RelNode, - rowRelDataType: RelDataType) - extends BiRel(cluster, traitSet, leftNode, rightNode) + inputs: JList[RelNode], + rowRelDataType: RelDataType, + all: Boolean) + extends Union(cluster, traitSet, inputs, all) --- End diff -- Change to `Union(cluster, traitSet, inputs, true)`
---