This is an automated email from the ASF dual-hosted git repository.
michaelsmith pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git
The following commit(s) were added to refs/heads/master by this push:
new b35aa8196 IMPALA-13045: Wait for impala_query_live to exist
b35aa8196 is described below
commit b35aa819653dce062109e61d8f30171234dce5f9
Author: Michael Smith <[email protected]>
AuthorDate: Mon Apr 29 11:56:46 2024 -0700
IMPALA-13045: Wait for impala_query_live to exist
Waits for creation of 'sys.impala_query_live' in tests to ensure it has
been registered with HMS.
Change-Id: I5cc3fa3c43be7af9a5f097359a0d4f20d057a207
Reviewed-on: http://gerrit.cloudera.org:8080/21372
Reviewed-by: Impala Public Jenkins <[email protected]>
Tested-by: Michael Smith <[email protected]>
---
tests/custom_cluster/test_query_live.py | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/tests/custom_cluster/test_query_live.py
b/tests/custom_cluster/test_query_live.py
index 25444d075..b1ffba09c 100644
--- a/tests/custom_cluster/test_query_live.py
+++ b/tests/custom_cluster/test_query_live.py
@@ -31,6 +31,13 @@ from time import sleep
class TestQueryLive(CustomClusterTestSuite):
"""Tests to assert the query live table is correctly populated."""
+ def setup_method(self, method):
+ super(TestQueryLive, self).setup_method(method)
+ create_match = self.assert_impalad_log_contains("INFO",
r'\]\s+(\w+:\w+)\]\s+'
+ r'Analyzing query: CREATE TABLE IF NOT EXISTS sys.impala_query_live')
+ self.assert_impalad_log_contains("INFO", r'Query successfully
unregistered: '
+ r'query_id={}'.format(create_match.group(1)))
+
def assert_impalads(self, profile, present=[0, 1, 2], absent=[]):
for port_idx in present:
assert ":" + str(DEFAULT_KRPC_PORT + port_idx) + ":" in profile
