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
commit f8d21f34bc6da6d6951eb835096082890482ea4a Author: jasonmfehr <[email protected]> AuthorDate: Wed Dec 3 16:25:33 2025 -0800 IMPALA-14602: Fix Flaky OTel Test Tests in test_otel_trace.py that rely on queries being queued assume a first long-running query will be started before a second query. These tests are flaky most likely because the first long running query is executed asynchronously immediately followed by executing a second query. During slower builds (such as ASAN), the first query may not be in running state before the second query is started. This patch adds a check on the first query to ensure it is running before starting the second query. Change-Id: I9e77ec70b4668f0daed2ab9411f8f6c52ddccb2a Reviewed-on: http://gerrit.cloudera.org:8080/23743 Reviewed-by: Riza Suminto <[email protected]> Tested-by: Impala Public Jenkins <[email protected]> --- tests/custom_cluster/test_otel_trace.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/custom_cluster/test_otel_trace.py b/tests/custom_cluster/test_otel_trace.py index b6d5a806a..94b798245 100644 --- a/tests/custom_cluster/test_otel_trace.py +++ b/tests/custom_cluster/test_otel_trace.py @@ -495,8 +495,9 @@ class TestOtelTraceSelectQueued(TestOtelTraceBase): """Tests that a query that is queued in admission control can be cancelled and the trace is created with the expected spans and events.""" # Start a long-running query that will take up the only admission control slot. - self.client.execute_async("SELECT * FROM functional.alltypes WHERE id = " + handle1 = self.client.execute_async("SELECT * FROM functional.alltypes WHERE id = " "SLEEP(5000)") + self.client.wait_for_impala_state(handle1, RUNNING, 60) # Start a second query that will be queued and then cancelled. handle2 = self.client.execute_async("SELECT * FROM functional.alltypes")
