litiliu opened a new issue, #7230: URL: https://github.com/apache/seatunnel/issues/7230
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened I'm run a seatunnel job with the Kafka connector on the Flink engine on the remote flink cluster, after the TM encountered a runtime exception, that job entered the restart mechanism(fixed-day 1s). After Flink's restart mechanism restored that job, we found the Kafka connector stopped ingesting any data. The reason is the running flag is false when it is restored.  ### SeaTunnel Version 2.3.5 ### SeaTunnel Config ```conf none ``` ### Running Command ```shell none ``` ### Error Exception ```log none ``` ### Zeta or Flink or Spark Version flink 1.15.4 ### Java or Scala Version java 1.8 ### Screenshots _No response_ ### 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: commits-unsubscr...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
