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