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 <[email protected]> Authored: Thu Mar 2 16:05:59 2017 -0800 Committer: Samarth <[email protected]> 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();
