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)