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 a9035f0f8e8d4f45583392c6a0fbf973de25c968 Author: Joe McDonnell <[email protected]> AuthorDate: Fri Jun 9 09:35:10 2023 -0700 IMPALA-12148: Bump timeouts for TestAsyncDDLTiming::test_ctas() TestAsyncDDLTiming::test_ctas() has been failing intermittently on ASAN test jobs and has been failing sporadically on all other types of test jobs. The test is running in parallel with other tests, so it is possible for the statement to take longer than expected. This bumps the timeout to avoid this flakiness. The actual test case is not testing that the statement is finishing in a particular amount of time. Testing: - Ran ASAN job Change-Id: I4030afad3a00c4492bf7296bde7b77e86437111f Reviewed-on: http://gerrit.cloudera.org:8080/20030 Reviewed-by: Impala Public Jenkins <[email protected]> Tested-by: Impala Public Jenkins <[email protected]> --- tests/metadata/test_ddl.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/tests/metadata/test_ddl.py b/tests/metadata/test_ddl.py index 296703301..308ed1e1c 100644 --- a/tests/metadata/test_ddl.py +++ b/tests/metadata/test_ddl.py @@ -1115,9 +1115,12 @@ class TestAsyncDDLTiming(TestDdlBase): # the execute call. This means that the sync and async cases are the same. assert client.get_state(handle) == pending_state - # Wait for the statement to finish with a timeout of 20 seconds - # (30 seconds without shortcircuit reads) - wait_time = 20 if IS_HDFS else 30 + # Wait for the statement to finish with a timeout of 40 seconds + # (60 seconds without shortcircuit reads). There are other tests running + # in parallel and ASAN can be slow, so this timeout has been bumped + # substantially to avoid flakiness. The actual test case does not depend + # on the statement finishing in a particular amount of time. + wait_time = 40 if IS_HDFS else 60 wait_start = time.time() self.wait_for_state(handle, finished_state, wait_time, client=client) wait_end = time.time()
