You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 陈卓宇 <25...@qq.com.INVALID> on 2022/04/20 09:05:37 UTC
K8s 相关的 Broken pipe (Write failed) 异常
大佬您好：
运行环境：k8s on session
flink版本：1.13.6
java:1.8
逻辑：flink mongodb cdc ETL操作
小弟发现线上环境出现了这样一条异常：
2022-04-20 15:11:49,218 WARN io.fabric8.kubernetes.client.dsl.internal.WatchConnectionManager [] - Exec Failure
java.net.SocketException: Broken pipe (Write failed)
at java.net.SocketOutputStream.socketWrite0(Native Method) ~[?:1.8.0_202]
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:111) ~[?:1.8.0_202]
at java.net.SocketOutputStream.write(SocketOutputStream.java:155) ~[?:1.8.0_202]
at sun.security.ssl.OutputRecord.writeBuffer(OutputRecord.java:431) ~[?:1.8.0_202]
at sun.security.ssl.OutputRecord.write(OutputRecord.java:417) ~[?:1.8.0_202]
at sun.security.ssl.SSLSocketImpl.writeRecordInternal(SSLSocketImpl.java:879) ~[?:1.8.0_202]
at sun.security.ssl.SSLSocketImpl.writeRecord(SSLSocketImpl.java:850) ~[?:1.8.0_202]
at sun.security.ssl.AppOutputStream.write(AppOutputStream.java:123) ~[?:1.8.0_202]
at org.apache.flink.kubernetes.shaded.okio.Okio$1.write(Okio.java:79) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.kubernetes.shaded.okio.AsyncTimeout$1.write(AsyncTimeout.java:180) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.kubernetes.shaded.okio.RealBufferedSink.flush(RealBufferedSink.java:224) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.WebSocketWriter.writeControlFrame(WebSocketWriter.java:146) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.WebSocketWriter.writeClose(WebSocketWriter.java:106) ~[flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket.writeOneFrame(RealWebSocket.java:508) [flink-dist_2.11-1.13.1.jar:1.13.1]
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket$1.run(RealWebSocket.java:159) [flink-dist_2.11-1.13.1.jar:1.13.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_202]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
2022-04-20 15:11:52,357 INFO org.apache.flink.kubernetes.highavailability.KubernetesLeaderRetrievalDriver [] - Creating a new watch on ConfigMap rent-trip-appoint-00000000000000000000000000000000-jobmanager-leader.
百度发现原因千奇百怪，所以想求教大佬，什么原因导致，如何解决异常
卓宇