You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by la...@apache.org on 2019/06/12 20:38:15 UTC
[phoenix] branch 4.x-HBase-1.3 updated: PHOENIX-5340 Set OMID's
wait strategy to LOW_CPU for tests.
This is an automated email from the ASF dual-hosted git repository.
larsh pushed a commit to branch 4.x-HBase-1.3
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x-HBase-1.3 by this push:
new 5479324 PHOENIX-5340 Set OMID's wait strategy to LOW_CPU for tests.
5479324 is described below
commit 54793248ef8ec3cf96d2eedce0ea04d7b655d8f1
Author: Lars Hofhansl <la...@apache.org>
AuthorDate: Wed Jun 12 13:38:34 2019 -0700
PHOENIX-5340 Set OMID's wait strategy to LOW_CPU for tests.
---
.../java/org/apache/phoenix/transaction/OmidTransactionProvider.java | 2 ++
1 file changed, 2 insertions(+)
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 87d7225..b1b9a62 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
@@ -32,6 +32,7 @@ import org.apache.omid.transaction.TTable;
import org.apache.omid.tso.TSOMockModule;
import org.apache.omid.tso.TSOServer;
import org.apache.omid.tso.TSOServerConfig;
+import org.apache.omid.tso.TSOServerConfig.WAIT_STRATEGY;
import org.apache.omid.tso.client.OmidClientConfiguration;
import org.apache.omid.tso.client.TSOClient;
import org.apache.phoenix.coprocessor.OmidGCProcessor;
@@ -127,6 +128,7 @@ public class OmidTransactionProvider implements PhoenixTransactionProvider {
tsoConfig.setPort(port);
tsoConfig.setConflictMapSize(config.getInt(OMID_TSO_CONFLICT_MAP_SIZE, DEFAULT_OMID_TSO_CONFLICT_MAP_SIZE));
tsoConfig.setTimestampType(config.get(OMID_TSO_TIMESTAMP_TYPE, DEFAULT_OMID_TSO_TIMESTAMP_TYPE));
+ tsoConfig.setWaitStrategy(WAIT_STRATEGY.LOW_CPU.toString());
Injector injector = Guice.createInjector(new TSOMockModule(tsoConfig));
tso = injector.getInstance(TSOServer.class);