Sergey Nuyanzin created FLINK-31802:
---------------------------------------
Summary: Python py37-cython: commands failed
Key: FLINK-31802
URL: https://issues.apache.org/jira/browse/FLINK-31802
Project: Flink
Issue Type: Bug
Reporter: Sergey Nuyanzin
{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)
