diff --git a/tests/custom_cluster/test_web_pages.py b/tests/custom_cluster/test_web_pages.py index 67d702ff9..2daff98c7 100644 --- a/tests/custom_cluster/test_web_pages.py +++ b/tests/custom_cluster/test_web_pages.py @@ -455,20 +455,26 @@ class TestWebPage(CustomClusterTestSuite): self.run_stmt_in_hive("set hive.exec.dynamic.partition.mode=nonstrict;" + insert_stmt) page = requests.get("http://localhost:25020/events").text # Wait until the batched events are being processed - while "a batch of" not in page: - time.sleep(1) - page = requests.get("http://localhost:25020/events").text + if not IMPALA_TEST_CLUSTER_PROPERTIES.is_hierarchical_event_processing_enabled(): + while "a batch of" not in page: + time.sleep(1) + page = requests.get("http://localhost:25020/events").text + expected_lines = [ + "Current Event Batch", "Metastore Event Batch:", + "Event ID starts from", "Event time starts from", + "Started processing the current batch at", + "Started processing the current event at", + "Current Metastore event being processed", + "(a batch of ", " events on the same table)", + ] + for expected in expected_lines: + assert expected in page, "Missing '%s' in events page:\n%s" % (expected, page) expected_lines = [ - "Lag Info", "Lag time:", "Current Event Batch", "Metastore Event Batch:", - "Event ID starts from", "Event time starts from", - "Started processing the current batch at", - "Started processing the current event at", - "Current Metastore event being processed", - "(a batch of ", " events on the same table)", - ] + "Lag Info", "Lag time:"] for expected in expected_lines: assert expected in page, "Missing '%s' in events page:\n%s" % (expected, page) + @SkipIfFS.hive @CustomClusterTestSuite.with_args( catalogd_args="--hms_event_polling_interval_s=1 "