In versions 1.17.1 and 1.18.1, I used the yarn per job mode to submit tasks, which will end in 4 minutes. But I tried it on Flink 1.13.1, 1.15.2, and 1.16.3, all of which were normal. command line at 1.17.1 version： ``` ./bin/flink run -t yarn-per-job -ys 1 -yjm 1G -ytm 3G -yqu default -p 1 -sae -c org.apache.flink.streaming.examples.socket.SocketWindowWordCount ./examples/streaming/SocketWindowWordCount.jar -hostname 192.168.2.111 -port 7777 ```
The logs are printed as follows at 1.17.1 version: ``` 2024-03-05 14:43:08,144 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - TumblingProcessingTimeWindows -> Sink: Print to Std. Out (1/1) (a23ddaf520a680f213db5726192b7dc4_90bea66de1c231edf33913ecd54406c1_0_0) switched from INITIALIZING to RUNNING. 2024-03-05 14:43:29,232 ERROR org.apache.flink.runtime.rest.handler.job.JobClientHeartbeatHandler [] - Exception occurred in REST handler: Request did not match expected format JobClientHeartbeatRequestBody. 2024-03-05 14:43:59,222 ERROR org.apache.flink.runtime.rest.handler.job.JobClientHeartbeatHandler [] - Exception occurred in REST handler: Request did not match expected format JobClientHeartbeatRequestBody. 2024-03-05 14:44:29,226 ERROR org.apache.flink.runtime.rest.handler.job.JobClientHeartbeatHandler [] - Exception occurred in REST handler: Request did not match expected format JobClientHeartbeatRequestBody. 2024-03-05 14:44:59,218 ERROR org.apache.flink.runtime.rest.handler.job.JobClientHeartbeatHandler [] - Exception occurred in REST handler: Request did not match expected format JobClientHeartbeatRequestBody. 2024-03-05 14:45:29,216 ERROR org.apache.flink.runtime.rest.handler.job.JobClientHeartbeatHandler [] - Exception occurred in REST handler: Request did not match expected format JobClientHeartbeatRequestBody. 2024-03-05 14:45:59,217 ERROR org.apache.flink.runtime.rest.handler.job.JobClientHeartbeatHandler [] - Exception occurred in REST handler: Request did not match expected format JobClientHeartbeatRequestBody. 2024-03-05 14:46:29,217 ERROR org.apache.flink.runtime.rest.handler.job.JobClientHeartbeatHandler [] - Exception occurred in REST handler: Request did not match expected format JobClientHeartbeatRequestBody. 2024-03-05 14:46:58,363 WARN org.apache.flink.runtime.dispatcher.MiniDispatcher [] - The heartbeat from the job client is timeout and cancel the job cd6e02e2d60ea07a21e2809000e078cb. You can adjust the heartbeat interval by 'client.heartbeat.interval' and the timeout by 'client.heartbeat.timeout' ``` I use hadoop version 3.1.1
