Mrhs121 commented on PR #10060: URL: https://github.com/apache/seatunnel/pull/10060#issuecomment-3536458001
@davidzollo I've encountered a problem and need your help. In Spark 2.4, the DataWriter interface does not have` close()` method, so when this test case runs on the Spark 2.4 engine and the job fails, the` close()` method of the `DorisSinkWriter `is never invoked. As a result, the scheduled thread for `checkDone ` inside the `DorisSinkWriter` remain alive and prevent the SeaTunnel job from terminating. Do you think it's reasonable to close these resources in the abortPrepare method? -- 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]
