Repository: hive Updated Branches: refs/heads/master 294665acf -> f4380f3b5
HIVE-19552: Enable TestMiniDruidKafkaCliDriver#druidkafkamini_basic.q (Nishant Bangarwa, reviewed by Jesus Camacho Rodriguez) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/f4380f3b Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f4380f3b Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f4380f3b Branch: refs/heads/master Commit: f4380f3b5ea7997185ceefb4315bc2e325c99c9f Parents: 294665a Author: Nishant Bangarwa <[email protected]> Authored: Wed Sep 12 09:58:45 2018 -0700 Committer: Jesus Camacho Rodriguez <[email protected]> Committed: Wed Sep 12 09:58:59 2018 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hive/cli/control/CliConfigs.java | 1 - .../src/main/java/org/apache/hadoop/hive/ql/QOutProcessor.java | 3 ++- .../results/clientpositive/druid/druidkafkamini_basic.q.out | 6 ++---- 3 files changed, 4 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/f4380f3b/itests/util/src/main/java/org/apache/hadoop/hive/cli/control/CliConfigs.java ---------------------------------------------------------------------- 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 3466bac..a3dcf98 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 class CliConfigs { 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"); http://git-wip-us.apache.org/repos/asf/hive/blob/f4380f3b/itests/util/src/main/java/org/apache/hadoop/hive/ql/QOutProcessor.java ---------------------------------------------------------------------- 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 1e4cddd..a17c508 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 class QOutProcessor { ".*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) { http://git-wip-us.apache.org/repos/asf/hive/blob/f4380f3b/ql/src/test/results/clientpositive/druid/druidkafkamini_basic.q.out ---------------------------------------------------------------------- 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 c4b7b6e..619b95e 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
