You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Robert Bradshaw (JIRA)" <ji...@apache.org> on 2019/01/21 13:11:00 UTC
[jira] [Commented] (BEAM-6473) Python Flink ValidatesRunner
test_flattened_side_input fails
[ https://issues.apache.org/jira/browse/BEAM-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16747929#comment-16747929 ]
Robert Bradshaw commented on BEAM-6473:
---------------------------------------
https://github.com/apache/beam/pull/7581
> Python Flink ValidatesRunner test_flattened_side_input fails
> ------------------------------------------------------------
>
> Key: BEAM-6473
> URL: https://issues.apache.org/jira/browse/BEAM-6473
> Project: Beam
> Issue Type: Test
> Components: runner-flink, sdk-py-core
> Reporter: Maximilian Michels
> Priority: Critical
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> The {{test_flattened_side_input}} test fails after merging [https://github.com/apache/beam/pull/7456]
> {noformat}
> 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
> {noformat}
> [https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink_PR/134/console]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)