luoluoyuyu opened a new pull request, #17913: URL: https://github.com/apache/iotdb/pull/17913
## Summary - Drop pipe tasks in sink → processor → source order so outbound transfer stops before historical source cleanup begins. - Track the processor thread currently inside `supply()` and interrupt it from `close()` via `compareAndSet`, avoiding stale-thread interrupts. - Let `start()` abort promptly on close/interrupt and unpin only the TsFile resources that were pinned but not yet supplied. ## Why On DROP PIPE, `close()` could block behind a long-running `supply()/start()` while processor and sink kept forwarding historical TsFile events even though the pipe had already disappeared from `SHOW PIPES`. ## Test plan - [x] `mvn spotless:apply -pl iotdb-core/datanode` - [ ] Reproduce pure historical pipe DROP and verify receiver stops receiving data immediately - [ ] Capture thread dump and confirm drop worker no longer waits long behind historical extraction Made with [Cursor](https://cursor.com) -- 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]
