?????????? ??????????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. ???????????????????????????????????????????????????????????????? ????
