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

[Bug] Fix NumberFormatException for partition cache (#6846)

Browse Source 
Fix #6845
This commit is contained in:
ChPi
2021-11-12 10:36:58 +08:00
committed by GitHub
parent 0ae6e92dd4
commit 667e8bdce3
1 changed files with 19 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
fe/fe-core/src/main/java/org/apache/doris/qe/cache/PartitionRange.java vendored
View File

@ -27,7 +27,6 @@ import org.apache.doris.analysis.LiteralExpr;
import org.apache.doris.analysis.IntLiteral;
import org.apache.doris.catalog.OlapTable;
import org.apache.doris.catalog.PartitionItem;
import org.apache.doris.catalog.PrimitiveType;
import org.apache.doris.catalog.RangePartitionInfo;
import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.Partition;
@ -149,17 +148,26 @@ public class PartitionRange {
public Date date;
public boolean init(Type type, String str) {
if (type.getPrimitiveType() == PrimitiveType.DATE) {
try {
date = df10.parse(str);
} catch (Exception e) {
LOG.warn("parse error str{}.", str);
switch (type.getPrimitiveType()) {
case DATE:
try {
date = df10.parse(str);
} catch (Exception e) {
LOG.warn("parse error str{}.", str);
return false;
}
keyType = KeyType.DATE;
break;
case TINYINT:
case SMALLINT:
case INT:
case BIGINT:
value = Long.parseLong(str);
keyType = KeyType.LONG;
break;
default:
LOG.info("PartitionCache not support such key type {}", type.toSql());
return false;
}
keyType = KeyType.DATE;
} else {
value = Long.valueOf(str);
keyType = KeyType.LONG;
}
return true;
}