This is an automated email from the ASF dual-hosted git repository. stigahuang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/impala.git
commit bde8cc4ae41fad03e1456ed35a63eaea8e2f9af5 Author: stiga-huang <[email protected]> AuthorDate: Wed Feb 26 10:51:46 2025 +0800 IMPALA-13799: Bumps timeout in waiting for catalog updates in tests EventProcessorUtils.wait_for_event_processing() is used in tests to wait for HMS events being processed by catalogd and all impalads receive the catalog updates. Currently, the timeout in waiting for catalog updates is 10s. However, there are some e2e tests like test_overlap_min_max_filters that run DDL/DMLs longer than 10s, which could block the catalog update for longer than 10s. When this util method is used in e2e tests, it could be impacted by other concurrent tests and time out. This patch deflake the issue by bumping the timeout to be 20s. Change-Id: If6a785e6d98572bf1a3fa3efc81d712c7ecc488e Reviewed-on: http://gerrit.cloudera.org:8080/22547 Reviewed-by: Impala Public Jenkins <[email protected]> Tested-by: Quanlong Huang <[email protected]> --- tests/util/event_processor_utils.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/tests/util/event_processor_utils.py b/tests/util/event_processor_utils.py index 2c3cb743d..1b1a23c8e 100644 --- a/tests/util/event_processor_utils.py +++ b/tests/util/event_processor_utils.py @@ -106,10 +106,12 @@ class EventProcessorUtils(object): EventProcessorUtils.wait_for_synced_event_id(timeout, error_status_possible, current_event_id) # Wait until the impalad catalog versions agree with the catalogd's version. + # Some tests like test_overlap_min_max_filters have DDLs that take longer than 10s. + # The catalog update might be blocked due to that. Use 20s as the timeout here. catalogd_version = impala_cluster.catalogd.service.get_catalog_version() for impalad in impala_cluster.impalads: impalad.service.wait_for_metric_value("catalog.curr-version", catalogd_version, - allow_greater=True) + timeout=20, allow_greater=True) @staticmethod def get_event_processor_metrics():
