Hello I am getting the following error with the job deployed Apache Flink #troubleshooting

Hello, I am getting the following error with the j...

Sumit Nekar

02/03/2023, 5:40 PM

Hello, I am getting the following error with the job deployed in application mode. This results in restart of some tasks.

Copy code

INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - JobManager for job 6f180ddd63b2de76c0148a53c092f02f with leader id a7b5b93e86521793b3e017e64695426c lost leadership.

Please suggest if we can tune any parameters prevent this issue. JobManager is configured with HA (single job manager) and deployed using flink k8s operator (native k8s - Flink 1.13.6)

Sumit Nekar

02/04/2023, 3:38 PM

Can this be root cause?

Copy code

java.io.EOFException: null
	at org.apache.flink.kubernetes.shaded.okio.RealBufferedSource.require(RealBufferedSource.java:61) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
	at org.apache.flink.kubernetes.shaded.okio.RealBufferedSource.readByte(RealBufferedSource.java:74) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
	at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.WebSocketReader.readHeader(WebSocketReader.java:117) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
	at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.WebSocketReader.processNextFrame(WebSocketReader.java:101) ~[flink-dist_2.12-1.13.6.jar:1.13.6]
	at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket.loopReader(RealWebSocket.java:274) [flink-dist_2.12-1.13.6.jar:1.13.6]

Matyas Orhidi

02/06/2023, 2:05 AM

Try Flink 1.16

👍 1

Open in Slack

Previous Next