Mrhs121 opened a new issue, #10059: URL: https://github.com/apache/seatunnel/issues/10059
### 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 1. In` DorisStreamLoad.stopLoad()`, the loading state is set to false prematurely, even before the `httpClient.execute` method returns a response result. This improper timing prevents subsequent error detection mechanisms that rely on the loading state from functioning correctly. 2. This prevents `getLoadFailedMsg() `from properly collecting error msg form http response 3. The loop in RecordBuffer.stopBufferData() may wait indefinitely due to inability to retrieve error messages 4. This ultimately leads to the task being trapped in a dead loop/infinite loop and causing the task to hang/terminate abnormally There is also another problem in DorisSinkWriter https://github.com/apache/seatunnel/blob/40320d866afe51da223dee2da33a5e7c9faecddc/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkWriter.java#L256-L267 1. Incomplete resource cleanup: When flush() throws an IOException, subsequent resource cleanup steps are skipped 2. Thread pool not closed: scheduledExecutorService can not be closed, causing background threads to continue running 3. Connection not released: dorisStreamLoad may not be properly closed, maintaining the connection with Doris ### SeaTunnel Version dev ### SeaTunnel Config ```conf Created from the web, without config ``` ### Running Command ```shell Created from the web, without command ``` ### Error Exception ```log Doris task blocked by infinite loop and unable to terminate ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots <img width="1250" height="129" alt="Image" src="https://github.com/user-attachments/assets/42e65bb4-0c64-4440-b543-9b31e51bd98d"; /> The task cannot be terminated normally ### 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
