Omid lowLatency support bug fix Signed-off-by: Ohad Shacham <oh...@yahoo-inc.com>
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/47bf31b3 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/47bf31b3 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/47bf31b3 Branch: refs/heads/omid2 Commit: 47bf31b30b226367a9e5f95cecaa277531206981 Parents: 8e4590e Author: Yonatan Gottesman <yonig...@gmail.com> Authored: Sun Oct 21 14:17:07 2018 +0300 Committer: Ohad Shacham <oh...@yahoo-inc.com> Committed: Tue Oct 23 10:56:40 2018 +0300 ---------------------------------------------------------------------- .../apache/phoenix/transaction/OmidTransactionProvider.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/47bf31b3/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionProvider.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionProvider.java b/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionProvider.java index e81991a..610a5d1 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionProvider.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/transaction/OmidTransactionProvider.java @@ -55,6 +55,7 @@ public class OmidTransactionProvider implements PhoenixTransactionProvider { private HBaseTransactionManager transactionManager = null; private volatile CommitTable.Client commitTableClient = null; + private CommitTable.Writer commitTableWriter = null; public static final OmidTransactionProvider getInstance() { return INSTANCE; @@ -151,8 +152,10 @@ public class OmidTransactionProvider implements PhoenixTransactionProvider { clientConf.setConflictAnalysisLevel(OmidClientConfiguration.ConflictDetectionLevel.ROW); clientConf.setHBaseConfiguration(config); commitTableClient = commitTable.getClient(); - - transactionManager = HBaseTransactionManager.builder(clientConf).commitTableClient(commitTableClient) + commitTableWriter = commitTable.getWriter(); + transactionManager = HBaseTransactionManager.builder(clientConf) + .commitTableClient(commitTableClient) + .commitTableWriter(commitTableWriter) .tsoClient(client).build(); } catch (IOException | InterruptedException e) { throw new SQLExceptionInfo.Builder(
