[
https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18005103#comment-18005103
]
shilei commented on FLINK-38098:
--------------------------------
I have found the cause of the problem, which is due to the deserialization of
the client heartbeat data. I will fix this problem, please assign the ticket to
me.
> When submitting a task with the flink run command, adding the -sae parameter
> will cause the task to be killed
> -------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-38098
> URL: https://issues.apache.org/jira/browse/FLINK-38098
> Project: Flink
> Issue Type: Bug
> Components: Runtime / REST
> Affects Versions: 1.19.0, 1.18.1, 1.20.0
> Environment: flink 1.18.1
> Reporter: shilei
> Priority: Major
>
> When using the *flink run* command to submit a task, adding the *-ase*
> parameter will cause the client heartbeat to time out, causing the task to be
> killed. The log is:
> 2025-01-15 23:38:48,799 ERROR
> org.apache.flink.runtime.rest.handler.job.JobClientHeartbeatHandler [] -
> Exception occurred in REST handler: Request did not match expected format
> JobClientHeartbeatRequestBody.
> 2025-01-15 23:39:17,214 WARN
> org.apache.flink.runtime.dispatcher.MiniDispatcher [] - The
> heartbeat from the job client is timeout and cancel the job
> e4d51b6309273d647b0429f2aa8b3ee4. You can adjust the heartbeat interval by
> 'client.heartbeat.interval' and the timeout by 'client.heartbeat.timeout'
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
