Repository: phoenix Updated Branches: refs/heads/5.x-HBase-2.0 d931f8c79 -> 63940f949
PHOENIX-4531 Delete on a table with a global mutable index can issue client-side deletes against the index-addendum(Vincent Poon) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/63940f94 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/63940f94 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/63940f94 Branch: refs/heads/5.x-HBase-2.0 Commit: 63940f9491f4159076239bdbcffa2aa9db0b0b7a Parents: d931f8c Author: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Authored: Wed Feb 21 19:15:08 2018 +0530 Committer: Rajeshbabu Chintaguntla <rajeshb...@apache.org> Committed: Wed Feb 21 19:15:08 2018 +0530 ---------------------------------------------------------------------- .../main/java/org/apache/phoenix/compile/DeleteCompiler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/63940f94/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 6224570..a4d9467 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 @@ -251,13 +251,13 @@ public class DeleteCompiler { MutationState state = new MutationState(tableRef, mutations, 0, maxSize, maxSizeBytes, connection); connection.getMutationState().join(state); for (int i = 0; i < otherTableRefs.size(); i++) { - MutationState indexState = new MutationState(otherTableRefs.get(i), indexMutations.get(i), 0, maxSize, maxSizeBytes, connection); + MutationState indexState = new MutationState(otherTableRefs.get(i), otherMutations.get(i), 0, maxSize, maxSizeBytes, connection); connection.getMutationState().join(indexState); } connection.getMutationState().send(); mutations.clear(); - if (indexMutations != null) { - for (MultiRowMutationState multiRowMutationState : indexMutations) { + if (otherMutations != null) { + for (MultiRowMutationState multiRowMutationState : otherMutations) { multiRowMutationState.clear(); } }