Repository: phoenix Updated Branches: refs/heads/4.x-cdh5.11 e1f00c298 -> 7f4730ed7
PHOENIX-4790 Addendum to check that query is a point lookup for delete not to run query Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/7f4730ed Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/7f4730ed Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/7f4730ed Branch: refs/heads/4.x-cdh5.11 Commit: 7f4730ed7d433b4d00abd1d28305f4fbbdf1e8f8 Parents: e1f00c2 Author: James Taylor <[email protected]> Authored: Wed Jul 11 22:01:14 2018 -0700 Committer: James Taylor <[email protected]> Committed: Wed Jul 11 22:05:49 2018 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/phoenix/compile/DeleteCompiler.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/7f4730ed/phoenix-core/src/main/java/org/apache/phoenix/compile/DeleteCompiler.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/compile/DeleteCompiler.java b/phoenix-core/src/main/java/org/apache/phoenix/compile/DeleteCompiler.java index 78b2db9..a214c24 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/compile/DeleteCompiler.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/compile/DeleteCompiler.java @@ -541,6 +541,9 @@ public class DeleteCompiler { Iterator<QueryPlan> iterator = queryPlans.iterator(); while (iterator.hasNext()) { QueryPlan plan = iterator.next(); + // Must be a point lookup in order to not run a query since + // we have to have the full key be enumerated. + noQueryReqd &= plan.getContext().getScanRanges().isPointLookup(); if (plan.getTableRef().getTable().getIndexType() == IndexType.LOCAL) { if (!plan.getContext().getDataColumns().isEmpty()) { iterator.remove();
