Dawid Wysakowicz created FLINK-24137:
----------------------------------------
Summary: Python tests fail with "Exception in thread
read_grpc_client_inputs"
Key: FLINK-24137
URL: https://issues.apache.org/jira/browse/FLINK-24137
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.14.0
Reporter: Dawid Wysakowicz
Fix For: 1.14.0
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23443&view=logs&j=9cada3cb-c1d3-5621-16da-0f718fb86602&t=c67e71ed-6451-5d26-8920-5a8cf9651901&l=24681
{code}
Sep 03 02:40:11
pyflink/table/tests/test_udtf.py::PyFlinkStreamUserDefinedFunctionTests::test_execute_from_json_plan
Sep 03 02:40:11
/__w/2/s/flink-python/.tox/py38-cython/lib/python3.8/site-packages/_pytest/threadexception.py:75:
PytestUnhandledThreadExceptionWarning: Exception in thread
read_grpc_client_inputs
Sep 03 02:40:11
Sep 03 02:40:11 Traceback (most recent call last):
Sep 03 02:40:11 File
"/__w/2/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/threading.py", line
932, in _bootstrap_inner
Sep 03 02:40:11 self.run()
Sep 03 02:40:11 File
"/__w/2/s/flink-python/dev/.conda/envs/3.8/lib/python3.8/threading.py", line
870, in run
Sep 03 02:40:11 self._target(*self._args, **self._kwargs)
Sep 03 02:40:11 File
"/__w/2/s/flink-python/.tox/py38-cython/lib/python3.8/site-packages/apache_beam/runners/worker/data_plane.py",
line 598, in <lambda>
Sep 03 02:40:11 target=lambda: self._read_inputs(elements_iterator),
Sep 03 02:40:11 File
"/__w/2/s/flink-python/.tox/py38-cython/lib/python3.8/site-packages/apache_beam/runners/worker/data_plane.py",
line 581, in _read_inputs
Sep 03 02:40:11 for elements in elements_iterator:
Sep 03 02:40:11 File
"/__w/2/s/flink-python/.tox/py38-cython/lib/python3.8/site-packages/grpc/_channel.py",
line 426, in __next__
Sep 03 02:40:11 return self._next()
Sep 03 02:40:11 File
"/__w/2/s/flink-python/.tox/py38-cython/lib/python3.8/site-packages/grpc/_channel.py",
line 826, in _next
Sep 03 02:40:11 raise self
Sep 03 02:40:11 grpc._channel._MultiThreadedRendezvous:
<_MultiThreadedRendezvous of RPC that terminated with:
Sep 03 02:40:11 status = StatusCode.CANCELLED
Sep 03 02:40:11 details = "Multiplexer hanging up"
Sep 03 02:40:11 debug_error_string =
"{"created":"@1630636798.176694842","description":"Error received from peer
ipv4:127.0.0.1:37661","file":"src/core/lib/surface/call.cc","file_line":1070,"grpc_message":"Multiplexer
hanging up","grpc_status":1}"
Sep 03 02:40:11 >
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
