[
https://issues.apache.org/jira/browse/BEAM-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16638964#comment-16638964
]
Micah Wylde commented on BEAM-5633:
-----------------------------------
On the client (sdk_worker) side, we see this error when the logging client
disconnects:
{code:java}
E1004 22:08:02.139750634 38 chttp2_transport.cc:1097] Received a GOAWAY
with error code ENHANCE_YOUR_CALM and debug data equal to "too_many_pings"
Exception in thread read_log_control_messages:
Traceback (most recent call last):
File "/usr/local/lib/python2.7/threading.py", line 801, in __bootstrap_inner
self.run()
File "/usr/local/lib/python2.7/threading.py", line 754, in run
self.__target(*self.__args, **self.__kwargs)
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/log_handler.py",
line 65, in <lambda>
target=lambda: self._read_log_control_messages(log_control_messages),
File
"/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/log_handler.py",
line 111, in _read_log_control_messages
for _ in log_control_iterator:
File "/usr/local/lib/python2.7/site-packages/grpc/_channel.py", line 350, in
next
return self._next()
File "/usr/local/lib/python2.7/site-packages/grpc/_channel.py", line 341, in
_next
raise self
_Rendezvous: <_Rendezvous of RPC that terminated with (StatusCode.UNAVAILABLE,
Socket closed)>{code}
> Python SDK harness logging client failure
> -----------------------------------------
>
> Key: BEAM-5633
> URL: https://issues.apache.org/jira/browse/BEAM-5633
> Project: Beam
> Issue Type: Bug
> Components: sdk-py-harness
> Reporter: Thomas Weise
> Priority: Major
> Labels: portability-flink
>
> After running a test with synthetic source for a few minutes, the logging
> client fails and all subsequent log output is not forwarded to the runner.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
