You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ra...@apache.org on 2018/02/21 13:46:30 UTC
phoenix git commit: PHOENIX-4531 Delete on a table with a global
mutable index can issue client-side deletes against the
index-addendum(Vincent Poon)
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 <ra...@apache.org>
Authored: Wed Feb 21 19:15:08 2018 +0530
Committer: Rajeshbabu Chintaguntla <ra...@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();
}
}