Caideyipi opened a new pull request, #18476:
URL: https://github.com/apache/iotdb/pull/18476

   ## Description
   
   Audit databases should be excluded from subscription sources, but the 
listening filter applied that exclusion to every pipe type. As a result, 
consensus pipes used by IoTConsensus V2 did not construct tasks for audit 
DataRegions, which could leave audit-region migration stuck while removing the 
old region peer.
   
   This change:
   
   - passes the pipe type through ConfigNode and DataNode DataRegion listening 
decisions;
   - excludes audit databases only for `SUBSCRIPTION` pipes, while keeping them 
available to `CONSENSUS` and `USER` pipes;
   - reports a missing region task meta as a contextual `PipeException` instead 
of an uninformative null dereference;
   - adds unit coverage for audit-database filtering by pipe type and the 
missing-task-meta diagnostic.
   
   ## Tests
   
   `mvn -o -pl iotdb-core/confignode,iotdb-core/datanode -am 
-Dtest=DataRegionListeningFilterTest,PipeDataNodeTaskAgentTest,AbstractOperatePipeProcedureV2Test
 -Dsurefire.failIfNoSpecifiedTests=false test`
   
   12 tests passed with no failures, errors, or skips.
   
   <hr>
   
   This PR has:
   - [x] been self-reviewed.
   - [x] added or updated unit tests to cover the new code paths.
   
   <hr>
   
   ##### Key changed/added classes
   
   - `DataRegionListeningFilter`
   - `PipeDataNodeBuilder`
   - `PipeDataNodeTaskAgent`
   - `AbstractOperatePipeProcedureV2`


-- 
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]

Reply via email to