[impala] 01/03: IMPALA-8798: Skip TestAutoScaling on EC runs

[ta...@apache.org]

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

commit 6dd36d9d1be7437d3d5e18088a5e85a380c11040
Author: Lars Volker <lv...@cloudera.com>
AuthorDate: Fri Jul 26 19:26:06 2019 -0700

    IMPALA-8798: Skip TestAutoScaling on EC runs
    
    TestAutoScaling uses ConcurrentWorkload, which does not set the
    required query options to scan erasure-coded files. This change
    disables the affected test when running with erasure-coding enabled.
    
    Change-Id: I96690914f12679619ba96d79edde8af9cccf65fa
    Reviewed-on: http://gerrit.cloudera.org:8080/13935
    Reviewed-by: Lars Volker <lv...@cloudera.com>
    Tested-by: Lars Volker <lv...@cloudera.com>
---
 tests/custom_cluster/test_auto_scaling.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/tests/custom_cluster/test_auto_scaling.py b/tests/custom_cluster/test_auto_scaling.py
index d0ab577..3c5ecca 100644
--- a/tests/custom_cluster/test_auto_scaling.py
+++ b/tests/custom_cluster/test_auto_scaling.py
@@ -23,6 +23,7 @@ from time import sleep, time
 from tests.util.auto_scaler import AutoScaler
 from tests.util.concurrent_workload import ConcurrentWorkload
 from tests.common.custom_cluster_test_suite import CustomClusterTestSuite
+from tests.common.skip import SkipIfEC
 
 LOG = logging.getLogger("test_auto_scaling")
 
@@ -47,6 +48,7 @@ class TestAutoScaling(CustomClusterTestSuite):
   def _get_num_running_queries(self):
     return self.impalad_test_service.get_num_running_queries("default-pool")
 
+  @SkipIfEC.fix_later
   def test_single_workload(self):
     """This test exercises the auto-scaling logic in the admission controller. It spins up
     a base cluster (coordinator, catalog, statestore), runs some queries to observe that
@@ -102,6 +104,7 @@ class TestAutoScaling(CustomClusterTestSuite):
       LOG.info("Stopping auto scaler")
       auto_scaler.stop()
 
+  @SkipIfEC.fix_later
   def test_single_group_maxed_out(self):
     """This test starts an auto scaler and limits it to a single executor group. It then
     makes sure that the query throughput does not exceed the expected limit."""
@@ -157,6 +160,7 @@ class TestAutoScaling(CustomClusterTestSuite):
       LOG.info("Stopping auto scaler")
       auto_scaler.stop()
 
+  @SkipIfEC.fix_later
   def test_sequential_startup(self):
     """This test starts an executor group sequentially and observes that no queries are
     admitted until the group has been fully started."""