Repository: impala Updated Branches: refs/heads/branch-3.1.0 f79f2d4ad -> 33d943b25
Revert "IMPALA-7148: Make test_profile_fragment_instances() more robust" This reverts commit 1d412a09ac807c2f7ab39ac4fdc3e21c29024190. Project: http://git-wip-us.apache.org/repos/asf/impala/repo Commit: http://git-wip-us.apache.org/repos/asf/impala/commit/bc9682b3 Tree: http://git-wip-us.apache.org/repos/asf/impala/tree/bc9682b3 Diff: http://git-wip-us.apache.org/repos/asf/impala/diff/bc9682b3 Branch: refs/heads/branch-3.1.0 Commit: bc9682b36cce72c5bf073048b1e7d0bcebb7728e Parents: f79f2d4 Author: Zoltan Borok-Nagy <borokna...@cloudera.com> Authored: Mon Nov 19 16:53:38 2018 +0100 Committer: Zoltan Borok-Nagy <borokna...@cloudera.com> Committed: Mon Nov 19 16:53:38 2018 +0100 ---------------------------------------------------------------------- tests/query_test/test_observability.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/impala/blob/bc9682b3/tests/query_test/test_observability.py ---------------------------------------------------------------------- diff --git a/tests/query_test/test_observability.py b/tests/query_test/test_observability.py index 2950ee8..c351e02 100644 --- a/tests/query_test/test_observability.py +++ b/tests/query_test/test_observability.py @@ -157,11 +157,9 @@ class TestObservability(ImpalaTestSuite): with l as (select * from tpch.lineitem UNION ALL select * from tpch.lineitem) select STRAIGHT_JOIN count(*) from (select * from tpch.lineitem a LIMIT 1) a join (select * from l LIMIT 2000000) b on a.l_orderkey = -b.l_orderkey;""") - # There are 3 scan nodes and each appears in the profile n+1 times (for n fragment - # instances + the averaged fragment). n depends on how data is loaded and scheduler's - # decision. - n = results.runtime_profile.count("HDFS_SCAN_NODE") - assert n > 0 and n % 3 == 0 + # There are 3 scan nodes and each appears in the profile 4 times (for 3 fragment + # instances + the averaged fragment). + assert results.runtime_profile.count("HDFS_SCAN_NODE") == 12 # There are 3 exchange nodes and each appears in the profile 2 times (for 1 fragment # instance + the averaged fragment). assert results.runtime_profile.count("EXCHANGE_NODE") == 6