From 9d5cab1e455e49354711b64681e32bae0c1c9e67 Mon Sep 17 00:00:00 2001 From: Nishant Date: Tue, 11 Sep 2018 12:58:21 -0700 Subject: [PATCH] [HIVE-19552] Enable TestMiniDruidKafkaCliDriver#druidkafkamini_basic.q --- .../main/java/org/apache/hadoop/hive/cli/control/CliConfigs.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/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java b/itests/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java index 3466bacd10..a3dcf9865d 100644 --- a/itests/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java +++ b/itests/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java @@ -202,7 +202,6 @@ public MiniDruidKafkaCliConfig() { setQueryDir("ql/src/test/queries/clientpositive"); includesFrom(testConfigProps, "druid.kafka.query.files"); - excludeQuery("druidkafkamini_basic.q"); // HIVE-19509 setResultsDir("ql/src/test/results/clientpositive/druid"); setLogDir("itests/qtest/target/tmp/log"); 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)