Repository: hive Updated Branches: refs/heads/branch-3 dbc5b176f -> f1d8c3f61
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/f1d8c3f6 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f1d8c3f6 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f1d8c3f6 Branch: refs/heads/branch-3 Commit: f1d8c3f614a15ebe691319e989dee906df15edd8 Parents: dbc5b17 Author: Nishant Bangarwa <[email protected]> Authored: Wed Sep 12 09:58:45 2018 -0700 Committer: Jesus Camacho Rodriguez <[email protected]> Committed: Wed Sep 12 10:00:23 2018 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/hive/ql/QOutProcessor.java | 3 ++- .../results/clientpositive/druid/druidkafkamini_basic.q.out | 6 ++---- 2 files changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/f1d8c3f6/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 359f027..400eec7 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/f1d8c3f6/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 ffd9279..b664e8c 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
