This is an automated email from the ASF dual-hosted git repository.

dbecker pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git

commit a0b3ae4e028330d26893fe1baeb715f425444b75
Author: Riza Suminto <[email protected]>
AuthorDate: Tue May 20 22:00:33 2025 -0700

    IMPALA-11396: Deflake test_low_mem_limit_orderby_all
    
    test_low_mem_limit_orderby_all is flaking if test_mem_limit equals 100
    and 120 in test vector. The minimum mem_limit to run this test is 120MB
    + 30MB = 150MB. Thus, this test vector expect one of
    MEM_LIMIT_ERROR_MSGS will be thrown because mem_limit (test_mem_limit)
    is not enough.
    
    Parquet scan under this low mem_limit sometimes throws "Couldn't skip
    rows in column" error instead. This possibly indicate memory exhaustion
    happen while reading parquet page index or late materialization (see
    IMPALA-5843, IMPALA-9873, IMPALA-11134). This patch attempt to deflake
    the test by adding "Couldn't skip rows in column" into
    MEM_LIMIT_ERROR_MSGS.
    
    Change-Id: I43a953bc19b40256e3a8fe473b1498bbe477c54d
    Reviewed-on: http://gerrit.cloudera.org:8080/22932
    Reviewed-by: Impala Public Jenkins <[email protected]>
    Tested-by: Impala Public Jenkins <[email protected]>
---
 tests/query_test/test_mem_usage_scaling.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/tests/query_test/test_mem_usage_scaling.py 
b/tests/query_test/test_mem_usage_scaling.py
index 60ae1fe4a..504ab76c3 100644
--- a/tests/query_test/test_mem_usage_scaling.py
+++ b/tests/query_test/test_mem_usage_scaling.py
@@ -41,7 +41,10 @@ from tests.verifiers.metric_verifier import MetricVerifier
 MEM_LIMIT_EXCEEDED_MSG = "Memory limit exceeded"
 MEM_LIMIT_TOO_LOW_FOR_RESERVATION = ("minimum memory reservation is greater 
than memory "
   "available to the query for buffer reservations")
-MEM_LIMIT_ERROR_MSGS = [MEM_LIMIT_EXCEEDED_MSG, 
MEM_LIMIT_TOO_LOW_FOR_RESERVATION]
+# IMPALA-11396: Error from parquet page index read if mem_limit is low.
+PARQUET_ROWS_SKIPPING = "Couldn't skip rows in column"
+MEM_LIMIT_ERROR_MSGS = [MEM_LIMIT_EXCEEDED_MSG, 
MEM_LIMIT_TOO_LOW_FOR_RESERVATION,
+                        PARQUET_ROWS_SKIPPING]
 
 
 @SkipIfNotHdfsMinicluster.tuned_for_minicluster

Reply via email to