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
The following commit(s) were added to refs/heads/master by this push:
new fd64c54f7 IMPALA-14059: deflake test_hms_event_sync_timeout
fd64c54f7 is described below
commit fd64c54f7deefe437dd122bb899625b379109fa7
Author: stiga-huang <[email protected]>
AuthorDate: Tue Jul 22 17:15:19 2025 +0800
IMPALA-14059: deflake test_hms_event_sync_timeout
test_hms_event_sync_timeout adds a sleep in events processing and runs a
SELECT in Impala after an INSERT in Hive. The Impala SELECT statement is
submitted with sync_hms_events_wait_time_s=2 and it's expected that
changes done in Hive haven't been applied in catalogd yet. However, the
changes is applied by a single event (ADD_PARTITION) and the event
processing delay is just 2s which is not longer enough. Sometimes the
event is applied just before the waitForHmsEvent request times out. So
the query still sees the latest results and fails the test.
This increases the event processing delay to 4s to deflake the test.
Change-Id: I91e9cbf234360446422259e274161a01a43ea3d9
Reviewed-on: http://gerrit.cloudera.org:8080/23207
Reviewed-by: Daniel Becker <[email protected]>
Tested-by: Impala Public Jenkins <[email protected]>
---
tests/custom_cluster/test_events_custom_configs.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tests/custom_cluster/test_events_custom_configs.py
b/tests/custom_cluster/test_events_custom_configs.py
index a13686700..17c56dd33 100644
--- a/tests/custom_cluster/test_events_custom_configs.py
+++ b/tests/custom_cluster/test_events_custom_configs.py
@@ -1728,7 +1728,7 @@ class
TestEventSyncFailures(TestEventProcessingCustomConfigsBase):
client.close_query(handle)
@CustomClusterTestSuite.with_args(
- catalogd_args="--debug_actions=catalogd_event_processing_delay:SLEEP@2000")
+ catalogd_args="--debug_actions=catalogd_event_processing_delay:SLEEP@4000")
def test_hms_event_sync_timeout(self, vector, unique_database):
client = self.default_impala_client(vector.get_value('protocol'))
# Timeline label shown in the profile when the wait failed.
