[
https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31802:
------------------------------------
Attachment: logs-cron_azure-test_cron_azure_python-1680752943.zip
> 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
> Affects Versions: 1.18.0
> Reporter: Sergey Nuyanzin
> Priority: Critical
> Labels: test-stability
> Attachments: logs-cron_azure-test_cron_azure_python-1680752943.zip
>
>
> {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)
