From 8e97eb99cf4c553a1b7f0c79fb2a5f55b78e191f Mon Sep 17 00:00:00 2001 From: Nishant Date: Mon, 27 Aug 2018 22:39:01 +0530 Subject: [PATCH] [HIVE-19552] Enable TestMiniDruidKafkaCliDriver#druidkafkamini_basic.q --- .../org/apache/hadoop/hive/cli/TestMiniDruidKafkaCliDriver.java | 1 - .../util/src/main/java/org/apache/hadoop/hive/ql/QOutProcessor.java | 3 ++- ql/src/test/results/clientpositive/druid/druidkafkamini_basic.q.out | 6 ++---- 3 files changed, 4 insertions(+), 6 deletions(-) diff --git a/itests/qtest/src/test/java/org/apache/hadoop/hive/cli/TestMiniDruidKafkaCliDriver.java b/itests/qtest/src/test/java/org/apache/hadoop/hive/cli/TestMiniDruidKafkaCliDriver.java index c54b2bf63a..b526c29cee 100644 --- a/itests/qtest/src/test/java/org/apache/hadoop/hive/cli/TestMiniDruidKafkaCliDriver.java +++ b/itests/qtest/src/test/java/org/apache/hadoop/hive/cli/TestMiniDruidKafkaCliDriver.java @@ -56,7 +56,6 @@ public TestMiniDruidKafkaCliDriver(String name, File qfile) { this.qfile = qfile; } - @Ignore("HIVE-19509: Disable tests that are failing continuously") @Test public void testCliDriver() throws Exception { adapter.runTest(name, qfile); diff --git a/itests/util/src/main/java/org/apache/hadoop/hive/ql/QOutProcessor.java b/itests/util/src/main/java/org/apache/hadoop/hive/ql/QOutProcessor.java index 1e4cddd4ec..a17c508624 100644 --- a/itests/util/src/main/java/org/apache/hadoop/hive/ql/QOutProcessor.java +++ b/itests/util/src/main/java/org/apache/hadoop/hive/ql/QOutProcessor.java @@ -121,7 +121,8 @@ public String get() { ".*at com\\.zaxxer.*", "org\\.apache\\.hadoop\\.hive\\.metastore\\.model\\.MConstraint@([0-9]|[a-z])*", "^Repair: Added partition to metastore.*", - "^Repair: Dropped partition from metastore.*" + "^latestOffsets.*", + "^minimumLag.*" }); public QOutProcessor(FsType fsType) { diff --git a/ql/src/test/results/clientpositive/druid/druidkafkamini_basic.q.out b/ql/src/test/results/clientpositive/druid/druidkafkamini_basic.q.out index c4b7b6ef6c..619b95e23a 100644 --- a/ql/src/test/results/clientpositive/druid/druidkafkamini_basic.q.out +++ b/ql/src/test/results/clientpositive/druid/druidkafkamini_basic.q.out @@ -72,8 +72,7 @@ Druid Storage Handler Runtime Status for default.druid_kafka_test kafkaPartitions=1 activeTasks=[] publishingTasks=[] -latestOffsets={0=10} -minimumLag={0=0} +#### A masked pattern was here #### aggregateLag=0 #### A masked pattern was here #### PREHOOK: query: Select count(*) FROM druid_kafka_test @@ -142,8 +141,7 @@ Druid Storage Handler Runtime Status for default.druid_kafka_test kafkaPartitions=1 activeTasks=[] publishingTasks=[] -latestOffsets={0=10} -minimumLag={0=0} +#### A masked pattern was here #### aggregateLag=0 #### A masked pattern was here #### PREHOOK: query: Select count(*) FROM druid_kafka_test -- 2.15.2 (Apple Git-101.1)