You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Sergey Nuyanzin (Jira)" <ji...@apache.org> on 2023/04/14 07:40:00 UTC
[jira] [Updated] (FLINK-31802) Python py37-cython: commands failed
[ https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sergey Nuyanzin updated FLINK-31802:
------------------------------------
Component/s: API / Python
> Python py37-cython: commands failed
> -----------------------------------
>
> Key: FLINK-31802
> URL: https://issues.apache.org/jira/browse/FLINK-31802
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Reporter: Sergey Nuyanzin
> Priority: Critical
> Labels: test-stability
>
> {noformat}
> Apr 06 05:55:13 ___________________________________ summary ____________________________________
> Apr 06 05:55:13 ERROR: py37-cython: commands failed
> Apr 06 05:55:13 py38-cython: commands succeeded
> Apr 06 05:55:13 py39-cython: commands succeeded
> Apr 06 05:55:13 py310-cython: commands succeeded
> {noformat}
> in logs there is such error for 37 not sure if it is related
> {noformat}
> 04:11:59,344 [grpc-default-executor-0] ERROR /__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py:294 [] - Error processing instruction 2. Original traceback is
> Traceback (most recent call last):
> File "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py", line 287, in _execute
> response = task()
> File "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py", line 360, in <lambda>
> lambda: self.create_worker().do_instruction(request), request)
> File "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py", line 597, in do_instruction
> getattr(request, request_type), request.instruction_id)
> File "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/sdk_worker.py", line 634, in process_bundle
> bundle_processor.process_bundle(instruction_id))
> File "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/bundle_processor.py", line 1004, in process_bundle
> element.data)
> File "/__w/1/s/flink-python/.tox/py37-cython/lib/python3.7/site-packages/apache_beam/runners/worker/bundle_processor.py", line 227, in process_encoded
> self.output(decoded_value)
> File "apache_beam/runners/worker/operations.py", line 526, in apache_beam.runners.worker.operations.Operation.output
> File "apache_beam/runners/worker/operations.py", line 528, in apache_beam.runners.worker.operations.Operation.output
> File "apache_beam/runners/worker/operations.py", line 237, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
> File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive
> File "apache_beam/runners/worker/operations.py", line 484, in apache_beam.runners.worker.operations.Operation.process
> File "/__w/1/s/flink-python/pyflink/fn_execution/beam/beam_operations_slow.py", line 152, in process
> o, self.operation.process_element(value)
> File "/__w/1/s/flink-python/pyflink/fn_execution/beam/beam_operations_slow.py", line 65, in process_outputs
> self._consumer.process(windowed_value.with_value(results))
> File "/__w/1/s/flink-python/pyflink/fn_execution/beam/beam_operations_slow.py", line 150, in process
> for value in o.value:
> File "/__w/1/s/flink-python/pyflink/fn_execution/datastream/process/input_handler.py", line 56, in process_element
> self._has_side_output)
> File "/__w/1/s/flink-python/pyflink/fn_execution/datastream/process/input_handler.py", line 131, in _emit_results
> for result in results:
> File "/__w/1/s/flink-python/pyflink/datastream/data_stream.py", line 1192, in process_element
> yield from self._flat_map_func(value)
> File "/__w/1/s/flink-python/pyflink/datastream/tests/test_data_stream.py", line 1628, in flat_map_func
> raise ValueError('flat_map_func error')
> ValueError: flat_map_func error
> {noformat}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=47960&view=logs&j=821b528f-1eed-5598-a3b4-7f748b13f261&t=6bb545dd-772d-5d8c-f258-f5085fba3295&l=29914
--
This message was sent by Atlassian Jira
(v8.20.10#820010)