谷金城 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)