Kyle Weaver created BEAM-9082:
---------------------------------
Summary: Spurious GRPC errors in Flink/Spark runner log output
Key: BEAM-9082
URL: https://issues.apache.org/jira/browse/BEAM-9082
Project: Beam
Issue Type: Improvement
Components: runner-flink, runner-spark
Reporter: Kyle Weaver
Assignee: Kyle Weaver
We often see "Socket closed" errors on job shutdown, even though the pipeline
has finished successfully. They are misleading and especially annoying at scale.
ERROR:root:Failed to read inputs in the data plane.
...
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string =
"{"created":"@1578597616.309419460","description":"Error received from peer
ipv6:[::1]:37211","file":"src/core/lib/surface/call.cc","file_line":1056,"grpc_message":"Socket
closed","grpc_status":14}"
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
