[BUG] fix DECHECK Fail While Call UDF (#5457)
This commit is contained in:
@ -251,7 +251,7 @@ public class AggregateFunction extends Function {
|
||||
}
|
||||
|
||||
public static AggregateFunctionBuilder createUdfBuilder() {
|
||||
return new AggregateFunctionBuilder(TFunctionBinaryType.HIVE);
|
||||
return new AggregateFunctionBuilder(TFunctionBinaryType.NATIVE);
|
||||
}
|
||||
|
||||
public AggregateFunctionBuilder name(FunctionName name) {
|
||||
|
||||
@ -236,7 +236,7 @@ public class ScalarFunction extends Function {
|
||||
Type returnType, boolean isVariadic,
|
||||
String objectFile, String symbol, String prepareFnSymbol, String closeFnSymbol) {
|
||||
ScalarFunction fn = new ScalarFunction(name, args, returnType, isVariadic);
|
||||
fn.setBinaryType(TFunctionBinaryType.HIVE);
|
||||
fn.setBinaryType(TFunctionBinaryType.NATIVE);
|
||||
fn.setUserVisible(true);
|
||||
fn.symbolName = symbol;
|
||||
fn.prepareFnSymbol = prepareFnSymbol;
|
||||
|
||||
Reference in New Issue
Block a user