[
https://issues.apache.org/jira/browse/BEAM-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16746873#comment-16746873
]
Valentyn Tymofieiev commented on BEAM-6469:
-------------------------------------------
PR7576 addressed the missing tenacity installation, the test suite however
failed with:
======================================================================
ERROR: test_flattened_side_input (__main__.FlinkRunnerTest)
----------------------------------------------------------------------
Traceback (most recent call last):(
File "apache_beam/runners/portability/fn_api_runner_test.py", line 205, in
test_flattened_side_input
label='CheckFlattenOfSideInput')
File "apache_beam/pipeline.py", line 425, in __exit__
self.run().wait_until_finish()
File "apache_beam/runners/portability/portable_runner.py", line 349, in
wait_until_finish
self._job_id, self._state, self._last_error_message()))
RuntimeError: Pipeline
test_flattened_side_input_1547859357.36_07dcde9b-acfc-4e8d-b930-582f7637a07e
failed in state FAILED: java.lang.IllegalArgumentException: PCollectionNodes
[PCollectionNode{id=ref_PCollection_PCollection_12, PCollection=unique_name:
"17side3/Map(decode).None"
coder_id: "ref_Coder_BytesCoder_1"
is_bounded: BOUNDED
windowing_strategy_id: "ref_Windowing_Windowing_1"
}] were consumed but never produced
----------------------------------------------------------------------
possibly a flake.
> Python Flink ValidatesRunner tests fail due to missing module
> -------------------------------------------------------------
>
> Key: BEAM-6469
> URL: https://issues.apache.org/jira/browse/BEAM-6469
> Project: Beam
> Issue Type: Test
> Components: sdk-py-core
> Reporter: Maximilian Michels
> Assignee: Valentyn Tymofieiev
> Priority: Blocker
> Fix For: 2.10.0
>
> Time Spent: 50m
> Remaining Estimate: 0h
>
> https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink_PR/130/console
> {noformat}
> 17:50:38 Traceback (most recent call last):
> 17:50:38 File "/usr/lib/python2.7/runpy.py", line 174, in
> _run_module_as_main
> 17:50:38 "__main__", fname, loader, pkg_name)
> 17:50:38 File "/usr/lib/python2.7/runpy.py", line 72, in _run_code
> 17:50:38 exec code in run_globals
> 17:50:38 File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python_VR_Flink_PR/src/sdks/python/apache_beam/runners/portability/flink_runner_test.py",
> line 37, in <module>
> 17:50:38 from apache_beam.runners.portability import portable_runner_test
> 17:50:38 File "apache_beam/runners/portability/portable_runner_test.py",
> line 42, in <module>
> 17:50:38 from apache_beam.runners.portability import fn_api_runner_test
> 17:50:38 File "apache_beam/runners/portability/fn_api_runner_test.py", line
> 29, in <module>
> 17:50:38 from tenacity import retry
> 17:50:38 ImportError: No module named tenacity
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
