fuweng11 opened a new issue, #7987: URL: https://github.com/apache/inlong/issues/7987
### Description Add a heartBeatTimeout status to the source. Currently streamSource has the following problems： 1.StreamSource information that is in the status to be delivered or modified cannot be deleted. 2.If the agent does not report data for a long time due to the abnormal status of the streamSource, streamSource information cannot be deleted or remains in the status `to be issued` for a long time. Solution： Currently, the Agent supports heartbeat reporting and automatic registration. After receiving the heartbeat information from the Agent, the Manager registers the corresponding cluster and node information and sets the node status to `NORMAL`. To solve the above two problems, the agent `HEARTBEAT_TIMEOUT` state is added to the streamSource. The streamSource in this state can be deleted but cannot be modified. In this case, if the Agent cluster corresponding to the data source to be delivered fails to report the heartbeat information due to various problems, the Manager does not receive the heartbeat information of the Agent for a long time and changes the node status to `HEARTBEAT_TIMEOUT` and change the status of the streamSource corresponding to the node to agent heartbeat Timeout. In this case, you can choose to delete the data source or wait for the recovery of the agent node to continue the task. If you choose to delete the data source, after the Agent node recovers, The Manager determines if the previous task needs to continue based on the is_deleted property of the current data source, if` is_delted! =0`, the current data source needs to be deleted. Therefore, the data source status is changed to to be deleted. To solve the above two problems. ### InLong Component InLong Manager ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@inlong.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
