You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2019/06/10 00:04:05 UTC
Build failed in Jenkins: beam_PostCommit_Python_VR_Spark #64
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/64/display/redirect>
------------------------------------------
[...truncated 1.06 MB...]
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_flattened_side_input_1560124998.34_1c08fea4-08a2-4dae-ae0d-7eb192a19c62 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/11/shuffle_10_2_0.data.68f9ec26-09bf-4b7b-86ee-76b419268d59 (No such file or directory)
======================================================================
ERROR: test_gbk_side_input (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 242, in test_gbk_side_input
equal_to([(None, {'a': [1]})]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_gbk_side_input_1560125002.63_dd826222-0d00-4980-afdd-e171400b92b2 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/09/temp_shuffle_37fcdb5a-241a-4152-bd27-549cbeb0d77d (No such file or directory)
======================================================================
ERROR: test_group_by_key (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 525, in test_group_by_key
assert_that(res, equal_to([('a', [1, 2]), ('b', [3])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_group_by_key_1560125005.67_8f7ee358-91dc-41e7-baea-8fca5a8ae30c failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/20/temp_shuffle_3043b477-3258-482c-a1ac-919f9fdef3ee (No such file or directory)
======================================================================
ERROR: test_large_elements (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 592, in test_large_elements
assert_that(gbk_res, equal_to(['a', 'b']), label='gbk')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_large_elements_1560125008.44_805a625e-b1b3-40dd-b114-353ea647ff6a failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/05/temp_shuffle_80f95402-9e66-4dfb-a007-042aedb4c564 (No such file or directory)
======================================================================
ERROR: test_multimap_side_input (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 253, in test_multimap_side_input
equal_to([('a', [1, 3]), ('b', [2])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_multimap_side_input_1560125010.04_d8762512-2ed2-4f7a-89f1-f5268725337f failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/14/temp_shuffle_4f26fd3b-3db4-4c8e-8424-e292ddd66616 (No such file or directory)
======================================================================
ERROR: test_multimap_side_input_type_coercion (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 266, in test_multimap_side_input_type_coercion
equal_to([('a', [1, 3]), ('b', [2])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_multimap_side_input_type_coercion_1560125011.48_f5d01a6d-f77f-4fcf-94ea-7b10da5b10b3 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/36/shuffle_20_0_0.index.3c5a49c0-83c1-4f41-b4d0-80ea59e36d93 (No such file or directory)
======================================================================
ERROR: test_no_subtransform_composite (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 642, in test_no_subtransform_composite
assert_that((pcoll_a, pcoll_b) | First(), equal_to(['a']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_no_subtransform_composite_1560125014.87_4c780a04-5fe4-4d72-9c4f-d3c6cc64dba0 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/27/temp_shuffle_f8fa2f91-dfef-4984-84e5-70a82c9e2c54 (No such file or directory)
======================================================================
ERROR: test_pardo (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 103, in test_pardo
assert_that(res, equal_to(['aax', 'bcbcx']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_1560125017.24_9ea2a27e-83b9-4f3c-ab28-2a80197aecf7 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/16/temp_shuffle_e42abbfa-0c0a-41c6-a12a-d61f759e4aa6 (No such file or directory)
======================================================================
ERROR: test_pardo_side_and_main_outputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 175, in test_pardo_side_and_main_outputs
assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_and_main_outputs_1560125019.21_0fdcad2f-02e6-4e74-aa3f-6cf4ec0e3a21 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/11/temp_shuffle_88233407-4322-493d-94ee-0813fa8e4429 (No such file or directory)
======================================================================
ERROR: test_pardo_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 186, in test_pardo_side_inputs
('a', 'y'), ('b', 'y'), ('c', 'y')]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_inputs_1560125023.08_b91136a4-c3a9-4082-b516-9dc3420daa45 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/13/temp_shuffle_a78a8930-9519-4daa-bacf-0e0c00c57783 (No such file or directory)
======================================================================
ERROR: test_pardo_side_outputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 157, in test_pardo_side_outputs
assert_that(xy.y, equal_to(['y', 'xy']), label='y')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_outputs_1560125026.33_8ee936bb-b973-4562-947b-7e1f0dd0f257 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/09/shuffle_28_1_0.data.412f34d7-ec55-4fa7-b4cc-91b060afd58d (No such file or directory)
======================================================================
ERROR: test_pardo_unfusable_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 276, in test_pardo_unfusable_side_inputs
equal_to([('a', 'a'), ('a', 'b'), ('b', 'a'), ('b', 'b')]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_unfusable_side_inputs_1560125029.53_ec3a1a1f-e190-4c83-8170-a9191a268de6 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/09/temp_shuffle_d45162d5-fb36-4b0e-8065-897f4109fdec (No such file or directory)
======================================================================
ERROR: test_pardo_windowed_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 213, in test_pardo_windowed_side_inputs
label='windowed')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_windowed_side_inputs_1560125031.35_798a507d-b37e-47f6-bfb9-c652c11fc026 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/27/temp_shuffle_c664793d-2269-48ff-bcb5-8c7a1e68df7a (No such file or directory)
======================================================================
ERROR: test_read (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 561, in test_read
equal_to(['a', 'b', 'c']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_read_1560125035.53_46b4c485-e456-4011-8eef-31de164828ff failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/11/shuffle_34_0_0.data.918492b8-b1b1-47d8-8812-e40e1a37391f (No such file or directory)
======================================================================
ERROR: test_reshuffle (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 531, in test_reshuffle
equal_to([1, 2, 3]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_reshuffle_1560125036.89_fc5ed69a-7dae-4aa7-8e65-870a96c7c943 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/00/temp_shuffle_4f26042a-1ee8-4c63-90e2-6eb8c476ffe5 (No such file or directory)
======================================================================
ERROR: test_sdf_wrap_range_source (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 517, in test_sdf_wrap_range_source
self._run_sdf_wrapper_pipeline(RangeSource(0, 4), [0, 1, 2, 3])
File "apache_beam/runners/portability/fn_api_runner_test.py", line 503, in _run_sdf_wrapper_pipeline
p | beam.io.Read(source)
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_sdf_wrap_range_source_1560125039.57_88118da9-2a5a-4c71-a403-046eb29702d0 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/1f/temp_shuffle_6435046a-5f01-4512-b138-ae0a03533ced (No such file or directory)
======================================================================
ERROR: test_sdf_wrapper_overrides_read (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/mock-2.0.0-py2.7.egg/mock/mock.py",> line 1305, in patched
return func(*args, **keywargs)
File "apache_beam/runners/portability/fn_api_runner_test.py", line 514, in test_sdf_wrapper_overrides_read
self._run_sdf_wrapper_pipeline(RangeSource(0, 4), ['1'])
File "apache_beam/runners/portability/fn_api_runner_test.py", line 503, in _run_sdf_wrapper_pipeline
p | beam.io.Read(source)
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_sdf_wrapper_overrides_read_1560125040.67_9c48817d-2041-4fe8-9758-6581757db111 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/36/shuffle_39_0_0.data.55d496db-1a0e-49db-8a7d-71ffe2e33ff4 (No such file or directory)
======================================================================
ERROR: test_windowing (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 573, in test_windowing
assert_that(res, equal_to([('k', [1, 2]), ('k', [100, 101, 102])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_windowing_1560125041.81_bea8070e-4fb6-477e-9b7a-f4c9da58d524 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b54ed1cb-30a1-49a7-a603-17369e14eb78/36/shuffle_42_0_0.index.accc02cd-f781-4663-bcb0-a71a5836308c (No such file or directory)
----------------------------------------------------------------------
Ran 37 tests in 70.939s
FAILED (errors=19, skipped=13)
> Task :sdks:python:sparkValidatesRunner FAILED
FAILURE: Build failed with an exception.
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/build.gradle'> line: 284
* What went wrong:
Execution failed for task ':sdks:python:sparkValidatesRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 3m 42s
60 actionable tasks: 47 executed, 13 from cache
Publishing build scan...
https://gradle.com/s/ujzgji3vdtyss
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Python_VR_Spark
#67
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/67/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_VR_Spark #66
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/66/display/redirect>
------------------------------------------
[...truncated 1.05 MB...]
File "apache_beam/runners/portability/fn_api_runner_test.py", line 543, in test_flatten
assert_that(res, equal_to(['a', 'b', 'c'] + additional))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_flatten_1560168196.63_acdce0eb-7491-45f3-82c2-a2e2e5b75a75 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/1d/shuffle_9_0_0.data.df256024-efef-476a-b808-cb0b266eae14 (No such file or directory)
======================================================================
ERROR: test_flattened_side_input (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/apache_beam/runners/portability/spark_runner_test.py",> line 144, in test_flattened_side_input
with_transcoding=False)
File "apache_beam/runners/portability/fn_api_runner_test.py", line 234, in test_flattened_side_input
label='CheckFlattenOfSideInput')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_flattened_side_input_1560168197.97_a797b104-16f8-4d65-b9d2-31c9c580c1d6 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/11/shuffle_10_2_0.data.1932c84c-51ca-4435-9f64-e5a990f879f1 (No such file or directory)
======================================================================
ERROR: test_gbk_side_input (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 242, in test_gbk_side_input
equal_to([(None, {'a': [1]})]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_gbk_side_input_1560168201.5_691ff8c5-c52a-46df-a25a-bcbfa7287989 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/11/shuffle_12_0_0.data.f8590f68-e64f-4b39-8710-33ee62a75041 (No such file or directory)
======================================================================
ERROR: test_group_by_key (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 525, in test_group_by_key
assert_that(res, equal_to([('a', [1, 2]), ('b', [3])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_group_by_key_1560168204.19_73d7b06f-437f-44a4-b4d3-8a790cb1da08 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/13/shuffle_14_0_0.data.38db22e5-6cf5-40b0-aa80-2b3b09d22d8f (No such file or directory)
======================================================================
ERROR: test_large_elements (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 592, in test_large_elements
assert_that(gbk_res, equal_to(['a', 'b']), label='gbk')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_large_elements_1560168206.82_fed4c709-2948-4fbb-977b-b503c81533c4 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/27/temp_shuffle_7ac21309-7d1b-4ca1-bbaa-ed2c37b60f49 (No such file or directory)
======================================================================
ERROR: test_multimap_side_input (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 253, in test_multimap_side_input
equal_to([('a', [1, 3]), ('b', [2])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_multimap_side_input_1560168213.08_3e0bed38-2ca9-46ef-8d2e-564a6f050f29 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/05/temp_shuffle_bd89fb20-4aea-46f8-b1a7-50f572377de6 (No such file or directory)
======================================================================
ERROR: test_multimap_side_input_type_coercion (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 266, in test_multimap_side_input_type_coercion
equal_to([('a', [1, 3]), ('b', [2])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_multimap_side_input_type_coercion_1560168214.48_85a113f2-8499-4d9a-80e8-b59fdf7b442c failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/08/shuffle_19_0_0.data.a9b5b690-64eb-44cd-a88e-4fc78b051b4b (No such file or directory)
======================================================================
ERROR: test_no_subtransform_composite (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 642, in test_no_subtransform_composite
assert_that((pcoll_a, pcoll_b) | First(), equal_to(['a']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_no_subtransform_composite_1560168215.87_a8ef9bdb-dbae-481f-9430-5daeb06809c1 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/27/temp_shuffle_0c76a129-ebd6-49b3-8ee8-a493a93d2baa (No such file or directory)
======================================================================
ERROR: test_pardo (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 103, in test_pardo
assert_that(res, equal_to(['aax', 'bcbcx']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_1560168217.97_4c0a629a-bc81-4220-ab6e-c04141d9d026 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/24/temp_shuffle_4f1c4f79-59de-4502-88f7-98ce4125a96c (No such file or directory)
======================================================================
ERROR: test_pardo_side_and_main_outputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 175, in test_pardo_side_and_main_outputs
assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_and_main_outputs_1560168221.0_1fed6617-3826-4fdb-b114-b07e1781f256 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/13/temp_shuffle_05ef8eaa-3513-440d-84ea-32a9d94aafd7 (No such file or directory)
======================================================================
ERROR: test_pardo_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 186, in test_pardo_side_inputs
('a', 'y'), ('b', 'y'), ('c', 'y')]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_inputs_1560168226.51_2e4dc492-1856-458e-a0bc-5b5c345a3fdb failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/0b/temp_shuffle_da6d6c93-577f-4c6b-ac89-22941699d23f (No such file or directory)
======================================================================
ERROR: test_pardo_side_outputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 157, in test_pardo_side_outputs
assert_that(xy.y, equal_to(['y', 'xy']), label='y')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_outputs_1560168229.66_fa968099-2e88-4ffc-9b5f-51e7faf4183d failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/13/temp_shuffle_72c76efb-28e8-4b2f-b9e5-f8f444d0e05d (No such file or directory)
======================================================================
ERROR: test_pardo_unfusable_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 276, in test_pardo_unfusable_side_inputs
equal_to([('a', 'a'), ('a', 'b'), ('b', 'a'), ('b', 'b')]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_unfusable_side_inputs_1560168232.07_7e81031b-4ce1-440c-b01a-7471a8b0523a failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/0e/temp_shuffle_c405d5ea-4b16-477c-82df-598802a2b75c (No such file or directory)
======================================================================
ERROR: test_pardo_windowed_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 213, in test_pardo_windowed_side_inputs
label='windowed')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_windowed_side_inputs_1560168233.45_974d880f-b36a-46c0-9911-b4ca4cd806a0 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/2d/shuffle_33_1_0.index.4cb8b469-1a87-43ba-8591-e97cf0d5d9f2 (No such file or directory)
======================================================================
ERROR: test_read (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 561, in test_read
equal_to(['a', 'b', 'c']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_read_1560168237.72_e0db7a0a-5909-4f72-a46c-658c23a5806c failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/0b/temp_shuffle_83b8fc08-6203-45c0-a62d-3088c8b5ad42 (No such file or directory)
======================================================================
ERROR: test_reshuffle (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 531, in test_reshuffle
equal_to([1, 2, 3]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_reshuffle_1560168239.04_69c689ca-5cc3-414d-bb0f-d291b3db87a1 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/24/temp_shuffle_39d0709e-64bd-4f83-89f0-10437d681336 (No such file or directory)
======================================================================
ERROR: test_sdf_wrap_range_source (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 517, in test_sdf_wrap_range_source
self._run_sdf_wrapper_pipeline(RangeSource(0, 4), [0, 1, 2, 3])
File "apache_beam/runners/portability/fn_api_runner_test.py", line 503, in _run_sdf_wrapper_pipeline
p | beam.io.Read(source)
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_sdf_wrap_range_source_1560168241.33_fa75c74f-ae99-4198-aa11-4fc00b821846 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/24/temp_shuffle_47e48d6a-69e7-4480-b5c4-f8c752380094 (No such file or directory)
======================================================================
ERROR: test_windowing (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 573, in test_windowing
assert_that(res, equal_to([('k', [1, 2]), ('k', [100, 101, 102])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_windowing_1560168244.72_a2a5f31c-b116-4468-b3a4-add962abc568 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-6ec61a12-c086-4007-822d-99902cf2da2c/0e/temp_shuffle_9bddff78-a196-4f07-adee-5713e1abc57b (No such file or directory)
----------------------------------------------------------------------
Ran 37 tests in 73.485s
FAILED (errors=18, skipped=13)
> Task :sdks:python:sparkValidatesRunner FAILED
FAILURE: Build failed with an exception.
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/build.gradle'> line: 284
* What went wrong:
Execution failed for task ':sdks:python:sparkValidatesRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 3m 46s
60 actionable tasks: 47 executed, 13 from cache
Publishing build scan...
https://gradle.com/s/4e3quzthnnaqw
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_VR_Spark #65
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/65/display/redirect>
------------------------------------------
[...truncated 1.01 MB...]
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_flattened_side_input_1560146593.95_25287155-ff8a-4e03-813c-8c8d294a36dd failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/3f/temp_shuffle_4ad0bf67-6c11-490f-952a-fa83a0e29fa1 (No such file or directory)
======================================================================
ERROR: test_gbk_side_input (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 242, in test_gbk_side_input
equal_to([(None, {'a': [1]})]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_gbk_side_input_1560146597.24_44ab1e82-1d79-4b66-b758-f61f7e35cd81 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/2c/shuffle_11_0_0.index.7931f6fd-ae9b-4ab7-8fdf-0c45418f56e8 (No such file or directory)
======================================================================
ERROR: test_group_by_key (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 525, in test_group_by_key
assert_that(res, equal_to([('a', [1, 2]), ('b', [3])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_group_by_key_1560146598.94_9819e9b9-7571-4bd3-9380-7453fa0194e6 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/13/shuffle_14_0_0.data.71c9d391-762d-4a59-b3cb-d89c71c72aad (No such file or directory)
======================================================================
ERROR: test_large_elements (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 592, in test_large_elements
assert_that(gbk_res, equal_to(['a', 'b']), label='gbk')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_large_elements_1560146600.24_64bd3154-ab9d-4372-bbe1-afee481b7f08 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/36/shuffle_16_1_0.data.94e52e29-5a0f-41ce-b815-e771ed3d0d92 (No such file or directory)
======================================================================
ERROR: test_multimap_side_input (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 253, in test_multimap_side_input
equal_to([('a', [1, 3]), ('b', [2])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_multimap_side_input_1560146605.58_d13951c6-f8ff-4132-a6e6-75e482196c23 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/0e/shuffle_17_0_0.index.85f31331-7972-4216-9d29-0740c8edc431 (No such file or directory)
======================================================================
ERROR: test_multimap_side_input_type_coercion (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 266, in test_multimap_side_input_type_coercion
equal_to([('a', [1, 3]), ('b', [2])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_multimap_side_input_type_coercion_1560146606.96_8a2b18a3-1c5e-4495-a384-06d814f2f0b5 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/0b/temp_shuffle_94c6a4c6-a6b1-425d-abd2-5742dc93ad93 (No such file or directory)
======================================================================
ERROR: test_no_subtransform_composite (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 642, in test_no_subtransform_composite
assert_that((pcoll_a, pcoll_b) | First(), equal_to(['a']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_no_subtransform_composite_1560146608.36_d48af5bb-4197-4cdc-ac3b-1ede0f83afb0 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/11/temp_shuffle_aa74c67c-ef02-4239-a500-2a07f3f64e2c (No such file or directory)
======================================================================
ERROR: test_pardo (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 103, in test_pardo
assert_that(res, equal_to(['aax', 'bcbcx']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_1560146611.34_d38e0cab-37d8-455b-9162-10e8fc82f4ef failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/11/shuffle_21_0_0.data.23d9291d-3265-4041-806e-b935b1dc571f (No such file or directory)
======================================================================
ERROR: test_pardo_side_and_main_outputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 175, in test_pardo_side_and_main_outputs
assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_and_main_outputs_1560146612.95_32cb52e4-60ff-4f9d-8f7a-40179e2cef1c failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/2f/temp_shuffle_293aff44-2f1b-4fd0-ba9f-7f06c4616c4d (No such file or directory)
======================================================================
ERROR: test_pardo_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 186, in test_pardo_side_inputs
('a', 'y'), ('b', 'y'), ('c', 'y')]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_inputs_1560146615.83_94bcaae0-4f50-485d-9c77-817b0fd61ce5 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/0b/shuffle_27_0_0.data.8df81c56-a186-4f20-abd6-0050d6707fa7 (No such file or directory)
======================================================================
ERROR: test_pardo_side_outputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 157, in test_pardo_side_outputs
assert_that(xy.y, equal_to(['y', 'xy']), label='y')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_side_outputs_1560146618.95_226847f1-e330-4ae9-abac-5234b4c23ae0 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/2d/shuffle_29_0_0.index.fd68b051-6d60-41b3-81b7-661699a0c1ee (No such file or directory)
======================================================================
ERROR: test_pardo_unfusable_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 276, in test_pardo_unfusable_side_inputs
equal_to([('a', 'a'), ('a', 'b'), ('b', 'a'), ('b', 'b')]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_unfusable_side_inputs_1560146620.33_e7304712-dbda-4549-8ae1-9cef3b26498c failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/09/temp_shuffle_7b5619eb-a94b-4d4b-af9a-ece3b84c85f4 (No such file or directory)
======================================================================
ERROR: test_pardo_windowed_side_inputs (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 213, in test_pardo_windowed_side_inputs
label='windowed')
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_pardo_windowed_side_inputs_1560146623.41_32afd9e9-ec95-42c9-8cb9-28da7a487a33 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/2d/temp_shuffle_1dbcc6e0-71d5-4959-bd09-01c1732e0f47 (No such file or directory)
======================================================================
ERROR: test_read (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 561, in test_read
equal_to(['a', 'b', 'c']))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_read_1560146625.35_d10c4e21-c057-46a8-88ae-65108e41916a failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/11/shuffle_34_0_0.data.23dd68b5-fbda-466e-a942-95e63a1384d9 (No such file or directory)
======================================================================
ERROR: test_reshuffle (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 531, in test_reshuffle
equal_to([1, 2, 3]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_reshuffle_1560146626.67_7878429d-d5cd-4d46-b8dd-5faeb250e5d7 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/13/temp_shuffle_2fa5147c-e4bd-4035-a586-5b1361d57282 (No such file or directory)
======================================================================
ERROR: test_sdf_wrap_range_source (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 517, in test_sdf_wrap_range_source
self._run_sdf_wrapper_pipeline(RangeSource(0, 4), [0, 1, 2, 3])
File "apache_beam/runners/portability/fn_api_runner_test.py", line 503, in _run_sdf_wrapper_pipeline
p | beam.io.Read(source)
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_sdf_wrap_range_source_1560146628.03_7dbb0eda-3423-4d92-93dc-d87a8b873eee failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/3d/temp_shuffle_bb6dc00e-a805-458c-808a-a377f7eda0bd (No such file or directory)
======================================================================
ERROR: test_sdf_wrapper_overrides_read (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/build/gradleenv/1922375555/local/lib/python2.7/site-packages/mock-2.0.0-py2.7.egg/mock/mock.py",> line 1305, in patched
return func(*args, **keywargs)
File "apache_beam/runners/portability/fn_api_runner_test.py", line 514, in test_sdf_wrapper_overrides_read
self._run_sdf_wrapper_pipeline(RangeSource(0, 4), ['1'])
File "apache_beam/runners/portability/fn_api_runner_test.py", line 503, in _run_sdf_wrapper_pipeline
p | beam.io.Read(source)
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_sdf_wrapper_overrides_read_1560146629.11_7de495db-27ba-4cf1-8cc2-5468e04b44e9 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/36/shuffle_39_0_0.data.fa86bde2-9218-465e-8568-24d7d9d94477 (No such file or directory)
======================================================================
ERROR: test_windowing (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 573, in test_windowing
assert_that(res, equal_to([('k', [1, 2]), ('k', [100, 101, 102])]))
File "apache_beam/pipeline.py", line 426, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 436, in wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline test_windowing_1560146630.21_30a4e39a-2802-4bf7-8d14-fe46010c5f7a failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b30e0a78-04f9-4165-9b54-706071e9bc04/07/temp_shuffle_028fc090-e4ea-471b-b997-5dcf0b232a9e (No such file or directory)
----------------------------------------------------------------------
Ran 37 tests in 67.891s
FAILED (errors=18, skipped=13)
> Task :sdks:python:sparkValidatesRunner FAILED
FAILURE: Build failed with an exception.
* Where:
Build file '<https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/ws/src/sdks/python/build.gradle'> line: 284
* What went wrong:
Execution failed for task ':sdks:python:sparkValidatesRunner'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 6.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/5.2.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 3m 37s
60 actionable tasks: 47 executed, 13 from cache
Publishing build scan...
https://gradle.com/s/xsespvmvklzxu
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org