database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Bug](function) forbid hll_union input not hll type param (#15397)

Browse Source 
forbid hll_union input not hll type param
This commit is contained in:
Pxl
2022-12-28 12:23:34 +08:00
committed by GitHub
parent d05f430ca2
commit 121f00b6e2
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
fe/fe-core/src/main/java/org/apache/doris/analysis/FunctionCallExpr.java
View File

@ -815,12 +815,13 @@ public class FunctionCallExpr extends Expr {
}
}
if ((fnName.getFunction().equalsIgnoreCase(FunctionSet.HLL_UNION_AGG)
|| fnName.getFunction().equalsIgnoreCase(FunctionSet.HLL_CARDINALITY)
|| fnName.getFunction().equalsIgnoreCase(FunctionSet.HLL_RAW_AGG))
if ((fnName.getFunction().equalsIgnoreCase("HLL_UNION_AGG")
|| fnName.getFunction().equalsIgnoreCase("HLL_CARDINALITY")
|| fnName.getFunction().equalsIgnoreCase("HLL_RAW_AGG")
|| fnName.getFunction().equalsIgnoreCase("HLL_UNION"))
&& !arg.type.isHllType()) {
throw new AnalysisException(
"HLL_UNION_AGG, HLL_RAW_AGG and HLL_CARDINALITY's params must be hll column");
"HLL_UNION, HLL_UNION_AGG, HLL_RAW_AGG and HLL_CARDINALITY's params must be hll column");
}
if (fnName.getFunction().equalsIgnoreCase("min")
@ -829,7 +830,7 @@ public class FunctionCallExpr extends Expr {
} else if (fnName.getFunction().equalsIgnoreCase("DISTINCT_PC")
|| fnName.getFunction().equalsIgnoreCase("DISTINCT_PCSA")
|| fnName.getFunction().equalsIgnoreCase("NDV")
|| fnName.getFunction().equalsIgnoreCase(FunctionSet.HLL_UNION_AGG)) {
|| fnName.getFunction().equalsIgnoreCase("HLL_UNION_AGG")) {
fnParams.setIsDistinct(false);
}