[BEAM-6473] Python Flink ValidatesRunner test_flattened_side_input fails

• Type: Test
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.11.0
• Component/s: runner-flink, sdk-py-core
• Assignee: Maximilian Michels
• Reporter: Maximilian Michels
• Created: 19/Jan/19 16:10
• Updated: 24/Jul/20 20:00
• Resolved: 04/Feb/19 11:12

Description

The test_flattened_side_input test fails after merging https://github.com/apache/beam/pull/7456

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

https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink_PR/134/console

Issue Links

• links to: GitHub Pull Request #7581
• links to: GitHub Pull Request #7640