See
<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/692/display/redirect?page=changes>
Changes:
[david.moravek] [BEAM-5790] Euphoria: Remove Dataset abstraction.
[david.moravek] [BEAM-5790] Euphoria: Fix missing website link.
[david.moravek] [BEAM-5790] Euphoria: Remove OutputBuilder where possible.
------------------------------------------
[...truncated 477.30 KB...]
assert_that(res, equal_to([('a', 1.5), ('b', 3.0)]))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_combine_per_key_1541785009.51_5e99c4b7-54ff-437b-b20d-2e55624b839e failed
in state FAILED.
======================================================================
ERROR: test_create (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 65, in
test_create
assert_that(p | beam.Create(['a', 'b']), equal_to(['a', 'b']))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_create_1541785009.89_366e73f1-ec17-4601-a9b5-7f6bee556b99 failed in state
FAILED.
======================================================================
ERROR: test_flatten (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 322, in
test_flatten
assert_that(res, equal_to(['a', 'b', 'c', 'd']))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_flatten_1541785010.41_81c79dc3-4ed7-4538-8cf9-bf7bddb800c8 failed in state
FAILED.
======================================================================
ERROR: test_flattened_side_input (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 206, in
test_flattened_side_input
equal_to([(None, {'a': 1, 'b': 2})]))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_flattened_side_input_1541785010.79_9bb7f2ac-32d7-4cea-85c3-88020db239ff
failed in state FAILED.
======================================================================
ERROR: test_gbk_side_input (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 217, in
test_gbk_side_input
equal_to([(None, {'a': [1]})]))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_gbk_side_input_1541785011.1_fa1d83d0-0817-4afc-9aa9-20659b5adf0e failed in
state FAILED.
======================================================================
ERROR: test_group_by_key (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 315, in
test_group_by_key
assert_that(res, equal_to([('a', [1, 2]), ('b', [3])]))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_group_by_key_1541785011.41_781bfed1-2c04-421e-bd24-dd131754171d failed in
state FAILED.
======================================================================
ERROR: test_large_elements (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 382, in
test_large_elements
assert_that(gbk_res, equal_to(['a', 'b']), label='gbk')
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_large_elements_1541785011.73_b5e8304d-016d-4b10-a647-bdda7d06d373 failed
in state FAILED.
======================================================================
ERROR: test_multimap_side_input (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 231, in
test_multimap_side_input
equal_to([('a', [1, 3]), ('b', [2])]))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_multimap_side_input_1541785012.22_da5dbe63-99a5-480c-b4f4-d06fa4ee59a9
failed in state FAILED.
======================================================================
ERROR: test_pardo (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 73, in
test_pardo
assert_that(res, equal_to(['aax', 'bcbcx']))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_pardo_1541785012.67_cb860165-4909-4eb0-864c-d870cb49db3a failed in state
FAILED.
======================================================================
ERROR: test_pardo_side_and_main_outputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 149, in
test_pardo_side_and_main_outputs
assert_that(unnamed.odd, equal_to([1, 3]), label='unnamed.odd')
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_pardo_side_and_main_outputs_1541785013.14_d7b65ef2-801e-4963-a771-7673881135a2
failed in state FAILED.
======================================================================
ERROR: test_pardo_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 163, in
test_pardo_side_inputs
('a', 'y'), ('b', 'y'), ('c', 'y')]))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_pardo_side_inputs_1541785014.11_4845714c-c399-4eff-9ea0-98d9ca3dd5aa
failed in state FAILED.
======================================================================
ERROR: test_pardo_side_outputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 131, in
test_pardo_side_outputs
assert_that(xy.y, equal_to(['y', 'xy']), label='y')
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_pardo_side_outputs_1541785014.49_c97a3cbc-a917-40b3-ad69-080fe8483b5f
failed in state FAILED.
======================================================================
ERROR: test_pardo_state_only (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 280, in
test_pardo_state_only
equal_to(expected))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_pardo_state_only_1541785014.95_48222d80-edbb-478c-9a94-9a725b768be3 failed
in state FAILED.
======================================================================
ERROR: test_pardo_unfusable_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 244, in
test_pardo_unfusable_side_inputs
equal_to([('a', 'a'), ('a', 'b'), ('b', 'a'), ('b', 'b')]))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_pardo_unfusable_side_inputs_1541785015.26_b782ccfa-39d4-425c-9c9c-a731bf7610c2
failed in state FAILED.
======================================================================
ERROR: test_pardo_windowed_side_inputs (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 193, in
test_pardo_windowed_side_inputs
label='windowed')
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_pardo_windowed_side_inputs_1541785015.55_2d88e9b8-b268-4ece-86ae-64e56b65b3e0
failed in state FAILED.
======================================================================
ERROR: test_read (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File
"<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py";,>
line 104, in test_read
assert_that(lines, lambda lines: len(lines) > 0)
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_read_1541785015.96_17e3b59f-a5b3-48bf-b77a-0aadd5d0b48c failed in state
FAILED.
======================================================================
ERROR: test_windowing (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "apache_beam/runners/portability/fn_api_runner_test.py", line 360, in
test_windowing
assert_that(res, equal_to([('k', [1, 2]), ('k', [100, 101, 102])]))
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 226, in
wait_until_finish
'Pipeline %s failed in state %s.' % (self._job_id, self._state))
RuntimeError: Pipeline
test_windowing_1541785016.25_e384b4bf-cc41-4709-bdc6-7075e42611e2 failed in
state FAILED.
----------------------------------------------------------------------
Ran 26 tests in 10.933s
FAILED (errors=17, skipped=7)
> Task :beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER FAILED
:beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER (Thread[Task worker
for ':' Thread 8,5,main]) completed. Took 12.921 secs.
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* Where:
Build file
'<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'>
line: 426
* What went wrong:
Execution failed for task
':beam-sdks-python:flinkCompatibilityMatrixBatchDOCKER'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Build file
'<https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/ws/src/sdks/python/build.gradle'>
line: 426
* What went wrong:
Execution failed for task
':beam-sdks-python:flinkCompatibilityMatrixStreamingDOCKER'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --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 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 6m 2s
60 actionable tasks: 55 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/kpy6cuh4zkozm
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org
