|
Change Variable Type iterator : AbstractMergeOuterJoinIterator<Tuple2<String,String>,Tuple2<String,Integer>,Tuple4<String,String,String,Object>> to iterator : AbstractMergeOuterJoinIterator in method private computeOuterJoin(input1 ResettableMutableObjectIterator<Tuple2<String,String>>, input2 ResettableMutableObjectIterator<Tuple2<String,Integer>>, outerJoinType OuterJoinType) : List<Tuple4<String,String,String,Object>> in class org.apache.flink.runtime.operators.sort.AbstractSortMergeOuterJoinIteratorITCase |
From |
To |