You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2022/05/04 20:33:00 UTC
[jira] [Work logged] (BEAM-14410) FnRunnerTest with non-trivial (order 1000 elements) input flakes in non-cython environment
[ https://issues.apache.org/jira/browse/BEAM-14410?focusedWorklogId=766264&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-766264 ]
ASF GitHub Bot logged work on BEAM-14410:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 04/May/22 20:32
Start Date: 04/May/22 20:32
Worklog Time Spent: 10m
Work Description: TheNeuralBit opened a new pull request, #17548:
URL: https://github.com/apache/beam/pull/17548
Reproduce issue discovered in #17384, verify that it afffects master branch and not just that PR.
GitHub Actions Tests Status (on master branch)
------------------------------------------------------------------------------------------------
[](https://github.com/apache/beam/actions?query=workflow%3A%22Build+python+source+distribution+and+wheels%22+branch%3Amaster+event%3Aschedule)
[](https://github.com/apache/beam/actions?query=workflow%3A%22Python+Tests%22+branch%3Amaster+event%3Aschedule)
[](https://github.com/apache/beam/actions?query=workflow%3A%22Java+Tests%22+branch%3Amaster+event%3Aschedule)
See [CI.md](https://github.com/apache/beam/blob/master/CI.md) for more information about GitHub Actions CI.
Issue Time Tracking
-------------------
Worklog Id: (was: 766264)
Remaining Estimate: 0h
Time Spent: 10m
> FnRunnerTest with non-trivial (order 1000 elements) input flakes in non-cython environment
> ------------------------------------------------------------------------------------------
>
> Key: BEAM-14410
> URL: https://issues.apache.org/jira/browse/BEAM-14410
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-core
> Reporter: Brian Hulette
> Priority: P2
> Labels: flake
> Time Spent: 10m
> Remaining Estimate: 0h
>
> See [https://github.com/apache/beam/pull/17384#issuecomment-1117418018]
>
> {code:java}
> apache_beam/runners/portability/fn_api_runner/fn_runner_test.py:141:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> apache_beam/pipeline.py:596: in __exit__
> self.result = self.run()
> apache_beam/pipeline.py:573: in run
> return self.runner.run_pipeline(self, self._options)
> apache_beam/runners/portability/fn_api_runner/fn_runner.py:200: in run_pipeline
> pipeline.to_runner_api(default_environment=self._default_environment))
> apache_beam/runners/portability/fn_api_runner/fn_runner.py:208: in run_via_runner_api
> return self.run_stages(stage_context, stages)
> apache_beam/runners/portability/fn_api_runner/fn_runner.py:409: in run_stages
> runner_execution_context, bundle_context_manager, bundle_input)
> apache_beam/runners/portability/fn_api_runner/fn_runner.py:742: in _execute_bundle
> bundle_manager))
> apache_beam/runners/portability/fn_api_runner/fn_runner.py:966: in _run_bundle
> data_input, data_output, input_timers, expected_timer_output)
> apache_beam/runners/portability/fn_api_runner/fn_runner.py:1309: in process_bundle
> output.transform_id).append(output.data)
> apache_beam/runners/portability/fn_api_runner/execution.py:242: in append
> windowed_key_value = coder_impl.decode_from_stream(input_stream, True)
> apache_beam/coders/coder_impl.py:1446: in decode_from_stream
> value = self._value_coder.decode_from_stream(in_stream, nested)
> apache_beam/coders/coder_impl.py:994: in decode_from_stream
> c in enumerate(self._coder_impls)
> apache_beam/coders/coder_impl.py:994: in <listcomp>
> c in enumerate(self._coder_impls)
> apache_beam/coders/coder_impl.py:617: in decode_from_stream
> return in_stream.read_all(nested)
> apache_beam/coders/slow_stream.py:137: in read_all
> return self.read(self.read_var_int64() if nested else self.size())
> apache_beam/coders/slow_stream.py:148: in read_var_int64
> byte = self.read_byte()
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <apache_beam.coders.slow_stream.InputStream object at 0x7f8433d63190> def read_byte(self):
> # type: () -> int
> self.pos += 1
> > return self.data[self.pos - 1]
> E IndexError: index out of rangeapache_beam/coders/slow_stream.py:142: IndexError{code}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)