[
https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410384#comment-17410384
]
Dian Fu commented on FLINK-24137:
---------------------------------
[~xtsong] I will take a look at this issue. I agree with [~hxbks2ks] that this
is the same problem as FLINK-24100 and so I will close FLINK-24100 and try to
fix this problem in this ticket since there are more instances and discussions
here.
> 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
> Priority: Blocker
> Labels: test-stability
> 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)
