PHOENIX-2562 Change commit call to send for batched autocommit deletes
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c027e0b0 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c027e0b0 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c027e0b0 Branch: refs/heads/4.x-HBase-1.0 Commit: c027e0b0ba61fca57e4e0f66647e61593be0586e Parents: 423bd13 Author: James Taylor <[email protected]> Authored: Mon Jan 4 12:11:00 2016 -0800 Committer: James Taylor <[email protected]> Committed: Mon Jan 4 12:11:59 2016 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/phoenix/compile/DeleteCompiler.java | 2 +- .../src/main/java/org/apache/phoenix/trace/PhoenixMetricsSink.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/c027e0b0/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 12aa7c5..ac9f7d1 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 @@ -172,7 +172,7 @@ public class DeleteCompiler { MutationState indexState = new MutationState(indexTableRef, indexMutations, 0, maxSize, connection); connection.getMutationState().join(indexState); } - connection.commit(); + connection.getMutationState().send(); mutations.clear(); if (indexMutations != null) { indexMutations.clear(); http://git-wip-us.apache.org/repos/asf/phoenix/blob/c027e0b0/phoenix-core/src/main/java/org/apache/phoenix/trace/PhoenixMetricsSink.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/trace/PhoenixMetricsSink.java b/phoenix-core/src/main/java/org/apache/phoenix/trace/PhoenixMetricsSink.java index c39df2c..00b6637 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/trace/PhoenixMetricsSink.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/trace/PhoenixMetricsSink.java @@ -192,7 +192,6 @@ public class PhoenixMetricsSink implements MetricsSink { public void flush() { try { this.conn.commit(); - this.conn.rollback(); } catch (SQLException e) { LOG.error("Failed to commit changes to table", e); }
