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 a3a725d8c IMPALA-14718: Fix flaky test test_confirm_individual_refresh
a3a725d8c is described below
commit a3a725d8c6365537d6605dd94f52fa92e1e51c2a
Author: Noemi Pap-Takacs <[email protected]>
AuthorDate: Fri Feb 20 13:45:43 2026 +0100
IMPALA-14718: Fix flaky test test_confirm_individual_refresh
The flakiness was introduced by 'test_table_repair': it executed a
global INVALIDATE METADATA that affected other tests running in
parallel.
'test_confirm_individual_refresh' failed because it was running
in parallel with 'test_iceberg.py::test_table_repair', which ran
an INVALIDATE METADATA exactly before a SELECT query of
'test_confirm_individual_refresh', which was checking that data in
its table is not reloaded. Due to the global invalidate, the data
was reloaded anyway.
Fix: instead of global INVALIDATE METADATA, 'test_table_repair'
only invalidates its own table now.
Change-Id: If798856ae9aa0c1cc429d49f0efd17acd7fa4333
Reviewed-on: http://gerrit.cloudera.org:8080/24011
Reviewed-by: Balazs Hevele <[email protected]>
Reviewed-by: Csaba Ringhofer <[email protected]>
Tested-by: Noemi Pap-Takacs <[email protected]>
---
tests/query_test/test_iceberg.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/tests/query_test/test_iceberg.py b/tests/query_test/test_iceberg.py
index e76c6c38b..ba56794a4 100644
--- a/tests/query_test/test_iceberg.py
+++ b/tests/query_test/test_iceberg.py
@@ -2295,7 +2295,8 @@ class TestIcebergV2Table(IcebergTestSuite):
data_files = self.filesystem_client.ls(DATA_PATH)
self.filesystem_client.delete_file_dir(DATA_PATH + "/" + data_files[0])
self.filesystem_client.delete_file_dir(DATA_PATH + "/" + data_files[1])
- self.execute_query_expect_success(impalad_client, "invalidate metadata")
+ self.execute_query_expect_success(
+ impalad_client, "invalidate metadata {0}".format(db_tbl))
result = self.execute_query_expect_success(
impalad_client, repair_query.format(db_tbl))
assert result.data[0] == \
