[
https://issues.apache.org/jira/browse/FLINK-31802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31802:
------------------------------------
Description:
{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}
Apr 06 04:26:30 ________ ERROR at setup of
ProcessWindowTests.test_count_sliding_window ________
Apr 06 04:26:30
Apr 06 04:26:30 cls = <class
'pyflink.datastream.tests.test_window.ProcessWindowTests'>
Apr 06 04:26:30
Apr 06 04:26:30 @classmethod
Apr 06 04:26:30 def setUpClass(cls):
Apr 06 04:26:30 super(PyFlinkStreamingTestCase, cls).setUpClass()
Apr 06 04:26:30 cls.env.set_parallelism(2)
Apr 06 04:26:30 > cls.env.set_runtime_mode(RuntimeExecutionMode.STREAMING)
Apr 06 04:26:30
Apr 06 04:26:30 pyflink/testing/test_case_utils.py:193:
Apr 06 04:26:30 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _
{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=24593]
was:
{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=24593
> 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}
> Apr 06 04:26:30 ________ ERROR at setup of
> ProcessWindowTests.test_count_sliding_window ________
> Apr 06 04:26:30
> Apr 06 04:26:30 cls = <class
> 'pyflink.datastream.tests.test_window.ProcessWindowTests'>
> Apr 06 04:26:30
> Apr 06 04:26:30 @classmethod
> Apr 06 04:26:30 def setUpClass(cls):
> Apr 06 04:26:30 super(PyFlinkStreamingTestCase, cls).setUpClass()
> Apr 06 04:26:30 cls.env.set_parallelism(2)
> Apr 06 04:26:30 >
> cls.env.set_runtime_mode(RuntimeExecutionMode.STREAMING)
> Apr 06 04:26:30
> Apr 06 04:26:30 pyflink/testing/test_case_utils.py:193:
> Apr 06 04:26:30 _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> _ _ _ _ _ _ _ _ _
> {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=24593]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
