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

   ## Description
   
   This PR fixes tree-model pure-data pipe synchronization when the receiver 
does not already have the source tree database.
   
   For pipe-generated tree inserts and TsFile loads, the receiver may carry an 
explicit tree database hint such as  oot.test.sg_0. Partition analysis uses 
this explicit database name directly, so the normal tree device-path based 
database auto-creation path is bypassed. As a result, receiver-side writes can 
repeatedly fail with Create DataPartition failed because the database ... is 
not exists.
   
   The PR:
   - auto-creates explicit tree database hints on the DataNode receiver before 
executing tree insert/load statements
   - recalculates database-level when rebuilding pipe tree load retry statements
   - preserves the tree database hint when LoadTsFile fallback conversion 
replays tablets
   - adds a unit test for retry tree load statement database-level 
reconstruction
   
   ## Verification
   
   - mvn -DskipTests spotless:apply -pl iotdb-core/datanode
   - git diff --check
   
   mvn '-Ddevelocity.off=true' compile -pl iotdb-core/datanode was also 
attempted, but the current workspace fails in unrelated existing 
datanode/generated sources, e.g. missing Accumulator, IFill, LinearFill, 
PipeProcessorSubtask#getDisplayTaskID(), and related symbols.


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