You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ma...@apache.org on 2017/03/16 21:11:54 UTC

[32/50] [abbrv] phoenix git commit: PHOENIX-3062 Ignore PhoenixTracingEndToEndIT till consensus is reached

PHOENIX-3062 Ignore PhoenixTracingEndToEndIT till consensus is reached


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/450766e7
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/450766e7
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/450766e7

Branch: refs/heads/calcite
Commit: 450766e79002a1ccf30c8c7db00b86b67aa14d62
Parents: 5d08b68
Author: Samarth <sa...@salesforce.com>
Authored: Thu Mar 2 16:05:59 2017 -0800
Committer: Samarth <sa...@salesforce.com>
Committed: Thu Mar 2 16:05:59 2017 -0800

----------------------------------------------------------------------
 .../org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java     | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/phoenix/blob/450766e7/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java b/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
index 19fc75f..5e05fe8 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/trace/PhoenixTracingEndToEndIT.java
@@ -56,7 +56,9 @@ import com.google.common.collect.ImmutableMap;
  * Test that the logging sink stores the expected metrics/stats
  */
 
-public class PhoenixTracingEndToEndIT extends BaseTracingTestIT {
+// Marking this class as abstract till PHOENIX-3062 is fixed.
+// FIXME: PHOENIX-3062
+public abstract class PhoenixTracingEndToEndIT extends BaseTracingTestIT {
 
     private static final Log LOG = LogFactory.getLog(PhoenixTracingEndToEndIT.class);
     private static final int MAX_RETRIES = 10;
@@ -137,7 +139,7 @@ public class PhoenixTracingEndToEndIT extends BaseTracingTestIT {
         receiver.receiveSpan(span);
 
         // wait for the tracer to actually do the write
-        latch.await();
+        assertTrue("Sink not flushed. commit() not called on the connection", latch.await(60, TimeUnit.SECONDS));
 
         // look for the writes to make sure they were made
         Connection conn = getConnectionWithoutTracing();