flink sql hop????????udaf????????????merge??????????????????????

Sun, 17 Jan 2021 22:53:15 -0800 

??????
    flink1.10.1 
sql??????hop??????udaf??merge??????????????????????????????????????????????????merge??????
org.apache.flink.table.planner.codegen.CodeGenException: No matching merge 
method found for AggregateFunction com.autoai.cns.udaf.PercentileUDAF'
????merge ??????????????????
1??ImperativeAggCodeGen????checkNeededMethods??????if (needMerge)  
 getUserDefinedMethod 
2??UserDefinedFunctionUtils????getUserDefinedMethod??????????????merge??????????????????????????merge????false,??????????????????????????????????flink??????bug
parameterClassEquals(methodSignature(i), clazz) ||
    parameterDataTypeEquals(internalTypes(i), dataTypes(i))


??????????
def merge(accumulator: ListBuffer[Float], its: Iterable[ListBuffer[Float]]): 
Unit = {
  its.foreach(i => accumulator ++ i)
}

回复