This is an automated email from the ASF dual-hosted git repository. arawat pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/impala.git
commit 5d2fc70423724e218547d5f428d49464c117ea73 Author: Riza Suminto <[email protected]> AuthorDate: Thu Feb 27 11:40:03 2025 -0800 IMPALA-12931: Deflake test_no_hms_event_incremental_refresh test_no_hms_event_incremental_refresh_transactional_table has been flaky for not meeting the last assertion. This patch attempt to deflake the tests by shortening the StatestoreD heartbeat duration and wait a little bit for StatestoreD propagation after HMS Event processor catch up. This is the same technique we use to deflake IMPALA-13701. Testing: - Loop tests 10 times and pass. Change-Id: If64c6803c37522cc948d0e3480350eaa8e54c8c3 Reviewed-on: http://gerrit.cloudera.org:8080/22562 Reviewed-by: Impala Public Jenkins <[email protected]> Tested-by: Impala Public Jenkins <[email protected]> --- tests/custom_cluster/test_events_custom_configs.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/tests/custom_cluster/test_events_custom_configs.py b/tests/custom_cluster/test_events_custom_configs.py index 16c52def8..a162b95ba 100644 --- a/tests/custom_cluster/test_events_custom_configs.py +++ b/tests/custom_cluster/test_events_custom_configs.py @@ -1254,7 +1254,8 @@ class TestEventProcessingCustomConfigs(TestEventProcessingCustomConfigsBase): # + "not opened and might already be cleaned up") @CustomClusterTestSuite.with_args( - catalogd_args="--hms_event_incremental_refresh_transactional_table=false") + catalogd_args="--hms_event_incremental_refresh_transactional_table=false", + statestored_args=STATESTORED_ARGS) def test_no_hms_event_incremental_refresh_transactional_table(self, unique_database): """IMPALA-12835: Test that Impala notices inserts to acid tables when hms_event_incremental_refresh_transactional_table is false. @@ -1268,12 +1269,16 @@ class TestEventProcessingCustomConfigs(TestEventProcessingCustomConfigsBase): self.run_stmt_in_hive( "create transactional table {} (i int){}".format(fq_tbl, part_create)) EventProcessorUtils.wait_for_event_processing(self) + # Wait for StatestoreD to propagate the update. + wait_single_statestore_heartbeat() # Load the table in Impala before INSERT self.client.execute("refresh " + fq_tbl) self.run_stmt_in_hive( "insert into {}{} values (1),(2),(3)".format(fq_tbl, part_insert)) EventProcessorUtils.wait_for_event_processing(self) + # Wait for StatestoreD to propagate the update. + wait_single_statestore_heartbeat() results = self.client.execute("select i from " + fq_tbl) assert results.data == ["1", "2", "3"]
