diff --git a/be/src/vec/exec/vtable_function_node.cpp b/be/src/vec/exec/vtable_function_node.cpp index 9909d954bda728..395cee36acd035 100644 --- a/be/src/vec/exec/vtable_function_node.cpp +++ b/be/src/vec/exec/vtable_function_node.cpp @@ -164,7 +164,6 @@ Status VTableFunctionNode::_get_expanded_block(RuntimeState* state, Block* outpu for (int i = 0; i < _fn_num; i++) { if (columns[i + _child_slots.size()]->is_nullable()) { _fns[i]->set_nullable(); - LOG(INFO) << "_fns[i]->set_nullable(): " << i + _child_slots.size(); } } diff --git a/be/src/vec/exprs/vectorized_fn_call.cpp b/be/src/vec/exprs/vectorized_fn_call.cpp index 9867f5f33cf68e..9cb173f0b75408 100644 --- a/be/src/vec/exprs/vectorized_fn_call.cpp +++ b/be/src/vec/exprs/vectorized_fn_call.cpp @@ -68,14 +68,12 @@ Status VectorizedFnCall::prepare(RuntimeState* state, const RowDescriptor& desc, _expr_name = fmt::format("VectorizedFnCall[{}](arguments={},return={})", _fn.name.function_name, get_child_names(), _data_type->get_name()); - LOG(INFO) << "_expr_name: " << _expr_name; if (_fn.binary_type == TFunctionBinaryType::RPC) { _function = FunctionRPC::create(_fn, argument_template, _data_type); } else if (_fn.binary_type == TFunctionBinaryType::JAVA_UDF) { if (config::enable_java_support) { if (_fn.is_udtf_function) { _function = FakeJavaUDTF::create(_fn, argument_template, _data_type); - // _function = JavaFunctionCall::create(_fn, argument_template, _data_type); } else { _function = JavaFunctionCall::create(_fn, argument_template, _data_type); } diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/udf/JavaUdtfBuilder.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/udf/JavaUdtfBuilder.java index 88ac5cc84d5594..85114f08e3f189 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/udf/JavaUdtfBuilder.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/udf/JavaUdtfBuilder.java @@ -17,6 +17,7 @@ package org.apache.doris.nereids.trees.expressions.functions.udf; +import org.apache.doris.common.Pair; import org.apache.doris.common.util.ReflectionUtils; import org.apache.doris.nereids.trees.expressions.Expression; import org.apache.doris.nereids.trees.expressions.functions.BoundFunction; @@ -73,14 +74,14 @@ public boolean canApply(List arguments) { } @Override - public BoundFunction build(String name, List arguments) { + public Pair build(String name, List arguments) { List exprs = arguments.stream().map(Expression.class::cast).collect(Collectors.toList()); List argTypes = udf.getSignatures().get(0).argumentsTypes; List processedExprs = Lists.newArrayList(); for (int i = 0; i < exprs.size(); ++i) { - processedExprs.add(TypeCoercionUtils.castIfNotSameType(exprs.get(i), ((DataType) argTypes.get(i)))); + processedExprs.add(TypeCoercionUtils.castIfNotSameType(exprs.get(i), argTypes.get(i))); } - return udf.withChildren(processedExprs); + return Pair.ofSame(udf.withChildren(processedExprs)); } }