Repository: phoenix Updated Branches: refs/heads/txn 42a1ffc7f -> 6235866e6
Remove tableRef from correct map as mutations are sent Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/6235866e Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/6235866e Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/6235866e Branch: refs/heads/txn Commit: 6235866e66a23f1f7a17925ef3101a87a0e847f7 Parents: 42a1ffc Author: James Taylor <[email protected]> Authored: Mon Apr 20 18:55:48 2015 -0700 Committer: James Taylor <[email protected]> Committed: Mon Apr 20 18:55:48 2015 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/phoenix/execute/MutationState.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/6235866e/phoenix-core/src/main/java/org/apache/phoenix/execute/MutationState.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/execute/MutationState.java b/phoenix-core/src/main/java/org/apache/phoenix/execute/MutationState.java index 7acc7b5..0209e28 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/execute/MutationState.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/execute/MutationState.java @@ -567,7 +567,7 @@ public class MutationState implements SQLCloseable { if (tableRef.getTable().getType() != PTableType.INDEX) { numRows -= valuesMap.size(); } - valuesMap.remove(tableRef); // Remove batches as we process them + mutations.remove(tableRef); // Remove batches as we process them } trace.close(); assert(numRows==0);
