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/08 06:04:20 UTC
Build failed in Jenkins: beam_PostCommit_Python_VR_Spark #56
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/56/display/redirect>
------------------------------------------
[...truncated 1.03 MB...]
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_combine_per_key_1559973794.22_8561e290-f86f-44c2-a8eb-712f095daf53 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/0d/shuffle_3_0_0.index.fed46977-5f4c-408a-b37e-67fe72308cf4 (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_1559973810.88_9de9c69d-6c73-4ab0-8e9b-70e3fda36e86 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/11/shuffle_10_2_0.data.b2c7c863-8152-46d2-83f3-d291e7fdf42d (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_1559973817.19_fb615857-724b-4c03-bc58-d6fec5a37c41 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/11/shuffle_12_0_0.data.4f77da3d-1eda-4ff1-af6f-e5d390cc119b (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_1559973821.21_807302b6-9000-40fe-b282-85a5a2627b4f failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/13/shuffle_14_0_0.data.418516ba-c4e8-435e-9a64-0845277a56d5 (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_1559973823.93_13c5c166-780a-4d15-b54e-a0159e36eabc failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/31/shuffle_16_0_0.index.3b8c951d-b8c8-4ad0-9272-7d77239d4427 (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_1559973825.47_48660060-6902-4b7e-b8d0-c17229b1076e failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/0e/shuffle_17_0_0.index.bb3cb511-6bef-4ee3-b1de-59c45ac64a22 (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_1559973826.92_797cb9bd-318a-48da-80a8-e0cad56200b7 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/33/shuffle_18_0_0.index.e654a947-dabc-4f24-a978-29a269e77c18 (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_1559973832.7_d7a04c81-9d61-4a11-926d-4f05390087e7 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/11/shuffle_21_0_0.data.9733007a-574c-47a3-86aa-f4e9823a7c31 (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_1559973834.19_7dddc3d7-9535-42a9-b300-1c8c46389ef7 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/36/temp_shuffle_c6f27830-179e-4fad-b0f6-dda6b0ecdb04 (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_1559973836.99_84b7e9e7-e54a-43c3-b293-eba06f33c2bf failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/31/temp_shuffle_230b128b-14d8-44a6-a7d3-25305a61aeca (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_1559973838.4_fa3eba1f-704b-42ab-9371-a8d6b203f6d5 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/0b/shuffle_27_0_0.data.618b9d6a-1fa0-495c-9dab-ceab783e1521 (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 286, 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_1559973845.31_6bb122c7-27bd-4e76-b918-066eebd812b4 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/0d/shuffle_30_0_0.data.17ad0087-0441-4b69-80ca-431f319db6fb (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_1559973848.54_6a35e6fa-d098-45cc-9473-1806c3bbb320 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/0d/temp_shuffle_4d4221e6-9160-4d8d-a237-c5ccdf66a1e0 (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_1559973849.95_88372200-9d21-4256-9323-800d27d5eab3 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/11/shuffle_34_0_0.data.7c20844e-2060-48d3-b8e9-a37e6a49b3a0 (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_1559973851.53_e8a92d71-d020-4196-942f-f588f4487a03 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/13/shuffle_36_0_0.data.4294c4bd-a0c5-47b9-b3c8-e7d151494170 (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_1559973854.0_88ac600c-43e9-4279-9c32-9f472b8e15a6 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/31/shuffle_38_0_0.index.b1b752d2-bb6a-457d-b22d-48d536c62533 (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_1559973855.16_9d61a18d-7848-4cc9-a1cd-ecb27b84ddc8 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/33/temp_shuffle_5c5d5041-a5dc-4e44-8408-b278a516cddf (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_1559973856.31_3db7b936-d7e2-4a70-8c2f-12c74d0a8677 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-29437dad-e8e4-4c4b-a1d4-c0578580d2f8/13/temp_shuffle_96dccc21-3d06-49a6-8f96-c874b578b7c1 (No such file or directory)
----------------------------------------------------------------------
Ran 37 tests in 76.096s
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 4m 2s
60 actionable tasks: 47 executed, 13 from cache
Publishing build scan...
https://gradle.com/s/r6m6iph53v52s
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
#59
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/59/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 #58
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/58/display/redirect>
------------------------------------------
[...truncated 955.87 KB...]
======================================================================
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_1560016999.39_3d422453-37ab-4929-9a4a-1f9584e9fc23 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/0b/temp_shuffle_495552d5-e20f-4d43-92de-f71427248ce4 (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_1560017005.73_f4559f62-2e44-4060-a4c4-a31040455a16 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/36/temp_shuffle_cf7ae7dc-48da-46b0-aa57-00b15d135d54 (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_1560017007.55_17fb312b-196a-4f5c-94c4-55e3a21d5e92 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/13/shuffle_14_0_0.data.195e688e-cc5f-47cc-a798-f40b309d2d99 (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_1560017008.89_15158441-e058-4985-84f4-e32fe5ac0393 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/36/shuffle_16_1_0.data.da10f65f-b29c-44dd-bee2-493b12af6817 (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_1560017014.87_dc23ecec-7076-4404-ae94-a0894720c5ef failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/2f/temp_shuffle_38769298-a4bd-45a4-857d-7f1161686bc8 (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_1560017016.81_9259206a-c82a-4cc3-b2fa-0a11eaa5ff93 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/0e/temp_shuffle_33f87528-f7d4-4b35-b4c2-19636c8ef3b3 (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_1560017018.26_ea13bf17-fb45-43f2-84aa-3e03aa52faca failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/08/shuffle_19_0_0.data.85a811ea-23ce-4920-a4b4-9ce08e6368ac (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_1560017020.45_16d21d5d-0627-4dba-a06a-9a88bf6e8a5d failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/11/shuffle_21_0_0.data.05e2304b-e678-400b-a95c-6e465d7ebce6 (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_1560017022.42_07eac2b0-b5c0-4332-b455-a89200026b68 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/2e/shuffle_24_0_0.data.156ca68e-eddb-497c-8444-529df83bdad9 (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_1560017025.27_12e4436d-73c4-4084-adac-4c88ccbb66a1 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/0b/shuffle_27_0_0.data.fc4cb418-cba5-4434-9df4-ddb9c8b0e7e5 (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_1560017028.75_b5e84507-18cb-42ef-bce9-0576f0fbd118 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/37/shuffle_29_0_0.data.a25c0ced-da93-4298-bb3c-ea262ca405a1 (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_1560017030.16_c93d35d9-6ccf-425e-8c6b-5b11cf2945bc failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/03/temp_shuffle_067b7323-a791-4e7c-9d0e-4882d7c87f22 (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_1560017033.29_e367170a-3431-4a52-982e-2ed394a14635 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/2f/shuffle_33_1_0.data.39be200d-46f8-4abd-a750-84ea5336b72c (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_1560017037.2_63134f45-b8e5-40c9-b74e-0d4a60405f7c failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/11/shuffle_34_0_0.data.0e2229d6-3311-4a5c-a2f7-ee22707dab83 (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_1560017040.09_4b137859-0011-4f49-8a67-d3b86da64244 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/21/temp_shuffle_2720470c-df58-4ef1-be37-62867e510c7e (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_1560017041.95_919610f1-a276-41d3-bba6-4895a5be3ecb failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/36/shuffle_39_0_0.data.d1b65adf-8c6a-433b-b049-9d9e1b8e74f2 (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_1560017045.14_5ad0a43c-b227-4bb6-8e59-119c1d3059f6 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/11/shuffle_43_0_0.data.d042221e-95d7-4ce4-940e-7b4b16d8c57d (No such file or directory)
======================================================================
FAIL: test_error_message_includes_stage (__main__.SparkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 607, in test_error_message_includes_stage
self.assertIn('StageC', message)
AssertionError: 'StageC' not found in u'Pipeline test_error_message_includes_stage_1560016995.66_c1ebf3ef-5834-4053-910f-c1f9b936690a failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-b39aa576-e750-4242-8e3b-f877c7c03c6a/37/shuffle_7_0_0.index.a85a256e-ba97-48b1-b742-5a7eaace39b5 (No such file or directory)'
----------------------------------------------------------------------
Ran 37 tests in 73.314s
FAILED (failures=1, 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 47s
60 actionable tasks: 47 executed, 13 from cache
Publishing build scan...
https://gradle.com/s/dm53l56bdikgu
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 #57
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Python_VR_Spark/57/display/redirect>
------------------------------------------
[...truncated 1.06 MB...]
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
... 3 more
19/06/08 12:04:04 INFO BeamFileSystemArtifactRetrievalService: Manifest at /tmp/sparktestqc9DpV/job_96700f2e-517c-43d1-850e-8e1c7b619a25/MANIFEST has 0 artifact locations
19/06/08 12:04:04 INFO BeamFileSystemArtifactStagingService: Removed dir /tmp/sparktestqc9DpV/job_96700f2e-517c-43d1-850e-8e1c7b619a25/
ERROR:root:java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/11/shuffle_43_0_0.data.b73e368a-9cba-4398-9137-311b86237d54 (No such file or directory)
INFO:root:Job state changed to FAILED
E
======================================================================
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_1559995396.81_bb6844f6-0790-44f1-ad36-751162fad7ce failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/11/shuffle_10_2_0.data.0e427d7d-0cb6-43fd-843d-2dd7ec2abe43 (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_1559995403.1_9c2f35f8-4436-4136-aefd-2e95182be956 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/11/shuffle_12_0_0.data.131ce79e-cbf5-4f02-8153-dbbee030abe5 (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_1559995405.87_ae020faa-b3aa-41d4-b12a-ed3a33ad368a failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/21/temp_shuffle_6d14c01a-8164-470c-a639-1af70ba8c854 (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_1559995407.68_18168a94-f85f-4007-a813-2e6c700aacd7 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/22/temp_shuffle_e53535b9-facc-43f9-a890-2845903612b9 (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_1559995409.17_64bae254-d856-470d-bd5f-0c6e10b85f52 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/0e/shuffle_17_0_0.index.4c713350-ffb3-4faa-99d7-5056bb5022af (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_1559995410.57_d9152959-3543-4429-89dc-3696be1b4645 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/36/shuffle_20_0_0.index.fd5ac60a-5827-4683-9ef3-1fe11c7d500a (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_1559995414.06_ccfe632c-ab32-42b7-b8d7-b47677a3fc26 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/11/shuffle_21_0_0.data.e265f161-0c9a-45e2-bdb3-b8c2ce471d38 (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_1559995416.26_c12efc0a-7a6a-41ec-8aae-dcbe950e26aa failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/34/shuffle_22_0_0.index.3ad4aa8c-d393-46f9-9e5d-237a21631bc8 (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_1559995422.7_b87a34eb-6e30-4189-9c29-20319b1e73d0 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/27/temp_shuffle_4d2fc14b-89e8-4cc9-9c79-65471f3be6e1 (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_1559995424.94_f2c8b310-44a8-45d4-8017-03f3d3978892 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/11/temp_shuffle_316fa351-1c89-426a-9322-d304f178910a (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_1559995426.3_d1a0fc7b-68a3-4f00-9237-2081dda30e91 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/18/temp_shuffle_7d860e0d-1c8f-47fc-b620-fecb8beba11a (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_1559995427.73_d3d02f26-8c03-4ee8-b5af-b38f59807956 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/24/temp_shuffle_9a67308d-49dd-4d78-9d0b-6a221269e3c8 (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_1559995431.75_a03d7b9a-b6a9-47ee-98a9-cf9af18440d4 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/21/temp_shuffle_5ba5ce0c-ccc8-45ad-a269-6ceeab1e3792 (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_1559995436.29_f656b0a7-ed01-4919-b1db-25b3c3f273c6 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/12/shuffle_35_0_0.index.348e1e78-61e9-4192-9567-4e4e5522dffd (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_1559995437.59_d8933675-4af8-43db-946c-64125ef09669 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/34/shuffle_37_0_0.data.926f77e2-75f0-4d17-a4fd-7e4067480a8e (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_1559995439.86_fef41aad-65f3-4e22-b33b-f08225703438 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/36/shuffle_39_0_0.data.29046efe-3ef6-485d-9300-db5c341d720c (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_1559995442.96_04e2c824-4fb2-4701-8bfd-f9e0cd9572a4 failed in state FAILED: java.io.FileNotFoundException: /tmp/blockmgr-dd638e28-7cce-45c6-944f-7dc187b9d687/11/shuffle_43_0_0.data.b73e368a-9cba-4398-9137-311b86237d54 (No such file or directory)
----------------------------------------------------------------------
Ran 37 tests in 77.780s
FAILED (errors=17, 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 49s
60 actionable tasks: 47 executed, 13 from cache
Publishing build scan...
https://gradle.com/s/f4bfcczova2wm
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