Caideyipi opened a new pull request, #18216: URL: https://github.com/apache/iotdb/pull/18216
## Summary - register data region sources in the per-pipe remaining event operator - include pending historical source resources that have not yet been materialized as events - add a unit test covering pending historical events in the remaining count This prevents the remaining event count from reporting zero while historical resources are still waiting in the source queue. ## Testing - `mvn spotless:apply -pl iotdb-core/datanode` (passed) - `mvn test -pl iotdb-core/datanode -Dtest=PipeDataNodeRemainingEventAndTimeOperatorTest -DfailIfNoTests=false` (timed out after 120 seconds without a compilation or test failure result) -- 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]
