You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by ta...@apache.org on 2019/11/21 00:13:08 UTC

[impala] 01/02: IMPALA-9167: stress/test_acid_stress.py gets TimeoutError on s3

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

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

View the commit online:
https://github.com/apache/impala/commit/a5f28487b407825fdf50a4e860c2b1be36e48bce

commit a5f28487b407825fdf50a4e860c2b1be36e48bce
Author: Zoltan Borok-Nagy <bo...@cloudera.com>
AuthorDate: Wed Nov 20 15:44:45 2019 +0100

    IMPALA-9167: stress/test_acid_stress.py gets TimeoutError on s3
    
    Test TestAcidInsertsBasic.test_read_hive_inserts fails on S3 with
    timeout. In our test environment Hive fails on non-HDFS filesystems
    like S3, so we add the annotation @SkipIfS3.hive to the tests that
    use Hive.
    
    I added this annotation to test_read_hive_inserts which unfortunately
    missed it.
    
    Change-Id: I82d0549d43938917db51f63c8e492b3c7dbd8cd8
    Reviewed-on: http://gerrit.cloudera.org:8080/14754
    Reviewed-by: Impala Public Jenkins <im...@cloudera.com>
    Tested-by: Impala Public Jenkins <im...@cloudera.com>
---
 tests/stress/test_acid_stress.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/tests/stress/test_acid_stress.py b/tests/stress/test_acid_stress.py
index 35c3fc6..ca14083 100644
--- a/tests/stress/test_acid_stress.py
+++ b/tests/stress/test_acid_stress.py
@@ -25,7 +25,7 @@ from multiprocessing.pool import ThreadPool
 
 from tests.common.impala_test_suite import ImpalaTestSuite
 from tests.common.parametrize import UniqueDatabase
-from tests.common.skip import SkipIfHive2
+from tests.common.skip import SkipIfHive2, SkipIfS3
 
 NUM_OVERWRITES = 2
 NUM_INSERTS_PER_OVERWRITE = 4
@@ -180,6 +180,7 @@ class TestAcidInsertsBasic(TestAcidStress):
            sleep_seconds=0.1)])
 
   @SkipIfHive2.acid
+  @SkipIfS3.hive
   @pytest.mark.execute_serially
   @pytest.mark.stress
   def test_read_hive_inserts(self, unique_database):