[impala] branch master updated: IMPALA-10733: Fix flaky TestKuduOperations.test_replica_selection

[bo...@apache.org]

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

boroknagyz 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 135870074 IMPALA-10733: Fix flaky TestKuduOperations.test_replica_selection
135870074 is described below

commit 1358700740dbeff799f6a6a95f95b1d9fe7281d2
Author: Tamas Mate <tm...@apache.org>
AuthorDate: Thu Apr 14 11:05:51 2022 +0200

    IMPALA-10733: Fix flaky TestKuduOperations.test_replica_selection
    
    This issue is related to IMPALA-11187, 'test_read_mode' can have
    unpredicted results by its nature, it sets the 'kudu_read_mode' to
    'READ_LATEST'. The 'test_replica_selection' runs just after
    'test_read_mode' and the Kudu tests use the same Impala client, thus
    'kudu_read_mode=READ_LATEST' persists.
    
    This commit set 'kudu_read_mode=READ_AT_SNAPSHOT' for
    'test_replica_selection'.
    
    Testing:
     - Ran 'test_replica_selection'
    
    Change-Id: Id98edf6af8ac67bab65d1c09d3e3b6f9343da854
    Reviewed-on: http://gerrit.cloudera.org:8080/18418
    Reviewed-by: Impala Public Jenkins <im...@cloudera.com>
    Tested-by: Impala Public Jenkins <im...@cloudera.com>
---
 tests/query_test/test_kudu.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/tests/query_test/test_kudu.py b/tests/query_test/test_kudu.py
index 890fac8ab..05f67f03f 100644
--- a/tests/query_test/test_kudu.py
+++ b/tests/query_test/test_kudu.py
@@ -554,6 +554,7 @@ class TestKuduOperations(KuduTestSuite):
     """This test verifies that scans work as expected with different replica selection.
     """
     table_name = "%s.replica_selection" % unique_database
+    cursor.execute("set kudu_read_mode=READ_AT_SNAPSHOT")
     cursor.execute("""create table %s (a int primary key, b string) partition by hash(a)
         partitions 8 stored as kudu""" % table_name)
     cursor.execute("""insert into %s select id, string_col from functional.alltypes