Repository: impala Updated Branches: refs/heads/branch-3.1.0 031d5690f -> 7d3e9beee
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/b0672c81 Tree: http://git-wip-us.apache.org/repos/asf/impala/tree/b0672c81 Diff: http://git-wip-us.apache.org/repos/asf/impala/diff/b0672c81 Branch: refs/heads/branch-3.1.0 Commit: b0672c81b1e6b7a7eb67f9d2e6180cdf2691a25e Parents: 031d569 Author: Zoltan Borok-Nagy <borokna...@cloudera.com> Authored: Tue Nov 27 11:56:29 2018 +0100 Committer: Zoltan Borok-Nagy <borokna...@cloudera.com> Committed: Tue Nov 27 11:56:29 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/b0672c81/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
