diff --git a/src/main/java/org/tikv/common/predicates/ScanSpec.java b/src/main/java/org/tikv/common/predicates/ScanSpec.java index 7f56595003c..9ccb3731f2e 100644 --- a/src/main/java/org/tikv/common/predicates/ScanSpec.java +++ b/src/main/java/org/tikv/common/predicates/ScanSpec.java @@ -109,7 +109,6 @@ void addRangePredicate(TiIndexColumn col, Expression predicate) { public ScanSpec build() { List points = new ArrayList<>(); - List pointTypes = new ArrayList<>(); Set pushedPredicates = new HashSet<>(); if (index != null) { for (TiIndexColumn indexColumn : index.getIndexColumns()) { @@ -118,10 +117,7 @@ public ScanSpec build() { break; } pushedPredicates.addAll(predicates); - TiColumnInfo tiColumnInfo = table.getColumn(indexColumn.getOffset()); - DataType type = tiColumnInfo.getType(); points.add(mergeCNFExpressions(predicates)); - pointTypes.add(type); } } Optional newRangePred =