Caideyipi opened a new pull request, #18534: URL: https://github.com/apache/iotdb/pull/18534
## Description Snapshot/history-only Pipe sources use a heartbeat-only realtime source. With IoTConsensus, a Pipe task can start on a replica before writes from another writer have been asynchronously applied. The historical scan then sees no TsFiles, emits its terminate event, and allows the Pipe to be auto-dropped before the delayed writes arrive. This change waits for all remote IoTConsensus writers to finish synchronizing their logs before a heartbeat-only DataRegion source begins historical extraction. The wait runs outside the DataRegion write lock so remote writes can still be applied. Other consensus protocols and realtime Pipe source modes retain the existing startup path. ## Verification - `mvn spotless:apply -pl iotdb-core/consensus,iotdb-core/datanode` - Consensus module compilation passed - DataNode full-module compilation is blocked locally by unrelated stale dependency/generated-source errors -- 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]
