谷金城 created FLINK-35352:
---------------------------

             Summary: Add -sae submit task to run for a period of time and 
automatically cancel
                 Key: FLINK-35352
                 URL: https://issues.apache.org/jira/browse/FLINK-35352
             Project: Flink
          Issue Type: Bug
          Components: API / Core
    Affects Versions: 1.18.1, 1.19.0, 1.17.2
         Environment: centos7.9
            Reporter: 谷金城


Add -sae submit task to run for a period of time and automatically cancel

I know Flink has added a heartbeat mechanism in recent versions, and it can be 
adjusted through client.startbeat. interval and client.startbeat. timeout. 
However, I found that although the client has heartbeat logs, the task will 
still be automatically canceled when the timeout is reached
I found through debugging the source code that there is a section of code that 
should have modified expiredTimestamp after receiving the heartbeat, but it was 
not successfully modified

I have fixed this bug locally and would like to submit it to the community



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to