Repository: beam Updated Branches: refs/heads/master d4de13718 -> 07d9bd5f8
Increase the memory threshold for the direct runner test Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/065a545a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/065a545a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/065a545a Branch: refs/heads/master Commit: 065a545ae098c8df81769e4c88c5031deef4494a Parents: d4de137 Author: Ahmet Altay <[email protected]> Authored: Thu Mar 30 17:08:00 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Thu Mar 30 17:08:00 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/pipeline_test.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/065a545a/sdks/python/apache_beam/pipeline_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/pipeline_test.py b/sdks/python/apache_beam/pipeline_test.py index d464fdb..ba219bf 100644 --- a/sdks/python/apache_beam/pipeline_test.py +++ b/sdks/python/apache_beam/pipeline_test.py @@ -253,7 +253,7 @@ class PipelineTest(unittest.TestCase): # Consumed memory should not be proportional to the number of maps. memory_threshold = ( - get_memory_usage_in_bytes() + (3 * len_elements * num_elements)) + get_memory_usage_in_bytes() + (5 * len_elements * num_elements)) # Plus small additional slack for memory fluctuations during the test. memory_threshold += 10 * (2 ** 20)
