Repository: phoenix Updated Branches: refs/heads/4.x-HBase-0.98 0f95d3403 -> b16cb265a
PHOENIX-3864 PhoenixConsumerIT is timing out frequently in 4.x-HBase-0.98 Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/b16cb265 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b16cb265 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b16cb265 Branch: refs/heads/4.x-HBase-0.98 Commit: b16cb265a617d23fc510862da27acdccc3944ad4 Parents: 0f95d34 Author: James Taylor <jamestay...@apache.org> Authored: Wed May 17 16:00:21 2017 -0700 Committer: James Taylor <jamestay...@apache.org> Committed: Wed May 17 16:00:21 2017 -0700 ---------------------------------------------------------------------- .../apache/phoenix/kafka/PhoenixConsumerIT.java | 24 +++++++++++--------- 1 file changed, 13 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/b16cb265/phoenix-kafka/src/it/java/org/apache/phoenix/kafka/PhoenixConsumerIT.java ---------------------------------------------------------------------- diff --git a/phoenix-kafka/src/it/java/org/apache/phoenix/kafka/PhoenixConsumerIT.java b/phoenix-kafka/src/it/java/org/apache/phoenix/kafka/PhoenixConsumerIT.java index cfec391..5965696 100644 --- a/phoenix-kafka/src/it/java/org/apache/phoenix/kafka/PhoenixConsumerIT.java +++ b/phoenix-kafka/src/it/java/org/apache/phoenix/kafka/PhoenixConsumerIT.java @@ -29,6 +29,16 @@ import java.sql.ResultSet; import java.sql.SQLException; import java.util.Properties; +import kafka.admin.AdminUtils; +import kafka.server.KafkaConfig; +import kafka.server.KafkaServer; +import kafka.utils.MockTime; +import kafka.utils.TestUtils; +import kafka.utils.Time; +import kafka.utils.ZKStringSerializer$; +import kafka.utils.ZkUtils; +import kafka.zk.EmbeddedZookeeper; + import org.I0Itec.zkclient.ZkClient; import org.apache.flume.Context; import org.apache.kafka.clients.producer.KafkaProducer; @@ -41,21 +51,13 @@ import org.apache.phoenix.kafka.consumer.PhoenixConsumer; import org.apache.phoenix.util.PropertiesUtil; import org.junit.After; import org.junit.Before; +import org.junit.Ignore; import org.junit.Test; import com.google.common.io.Resources; -import kafka.admin.AdminUtils; -import kafka.server.KafkaConfig; -import kafka.server.KafkaServer; -import kafka.utils.MockTime; -import kafka.utils.TestUtils; -import kafka.utils.Time; -import kafka.utils.ZKStringSerializer$; -import kafka.utils.ZkUtils; -import kafka.zk.EmbeddedZookeeper; - -public class PhoenixConsumerIT extends BaseHBaseManagedTimeIT { +@Ignore("Remove tag and make class concrete again when PHOENIX-3864 is fixed and test no longer times out") +public abstract class PhoenixConsumerIT extends BaseHBaseManagedTimeIT { private static final String ZKHOST = "127.0.0.1"; private static final String BROKERHOST = "127.0.0.1"; private static final String BROKERPORT = "9092";
