diff --git a/tests/comparison/cluster.py b/tests/comparison/cluster.py index a2d8fc010db..33f29a9abf2 100644 --- a/tests/comparison/cluster.py +++ b/tests/comparison/cluster.py @@ -845,8 +845,10 @@ def web_ui_port(self): def find_pid(self): # Need to filter results to avoid pgrep picking up its parent bash script. - pid = self.shell("pgrep -f -a 'impalad.*%s' | grep -v pgrep | " - "grep -o '^[0-9]*' || true" % self.hs2_port) + # Test with: + # sh -c "pgrep -l -f 'impala.*21050' | grep [i]mpalad | grep -o '^[0-9]*' || true" + pid = self.shell("pgrep -l -f 'impalad.*%s' | grep [i]mpalad | " + "grep -o '^[0-9]*' || true" % self.hs2_port) if pid: return int(pid) diff --git a/tests/infra/test_stress_infra.py b/tests/infra/test_stress_infra.py index a11116f3642..bdbcdc755cf 100644 --- a/tests/infra/test_stress_infra.py +++ b/tests/infra/test_stress_infra.py @@ -17,13 +17,14 @@ # This module attempts to enforce infrastructural assumptions that bind test tools to # product or other constraints. We want to stop these assumptions from breaking at -# pre-commit time, not later. +# pre-merge time, not later. import pytest from decimal import Decimal from tests.common.impala_test_suite import ImpalaTestSuite +from tests.common.skip import SkipIfBuildType from tests.comparison.cluster import MiniCluster from tests.util.parse_util import ( EXPECTED_TPCDS_QUERIES_COUNT, EXPECTED_TPCH_NESTED_QUERIES_COUNT, @@ -34,6 +35,10 @@ class TestStressInfra(ImpalaTestSuite): + @classmethod + def get_workload(cls): + return 'functional-query' + def test_stress_binary_search_start_point(self): """ Test that the stress test can use EXPLAIN to find the start point for its binary @@ -62,10 +67,13 @@ def test_stress_finds_workloads(self, count_map): for name in queries: assert name is not None + @SkipIfBuildType.remote def tests_minicluster_obj(self): """ Test that the minicluster abstraction finds the minicluster. """ + if self.exploration_strategy() == "exhaustive": + pytest.skip("Test does not need to run in exhaustive") cluster = MiniCluster() if IS_LOCAL: expected_pids = 1