Skip to content

Commit 9558aae

Browse files
committed
Clarify write-back sink target database normalization
1 parent abdd389 commit 9558aae

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -333,8 +333,9 @@ private void customizeTargetDatabase(final String targetDatabase) {
333333
invalidTargetTableModelDatabaseName = null;
334334
targetTreeModelDatabaseName = null;
335335

336-
// Write-back sink may receive both table-model and tree-model events from one pipe.
337-
// Normalize one configured target database to both model names so each event can be rewritten.
336+
// The sink only sees its own parameters during customization, without the pipe's isolated
337+
// runtime model. Normalize one configured target database to both model names, and later use
338+
// the one matching the incoming event model.
338339
if (PathUtils.isTableModelDatabase(targetDatabase)) {
339340
targetTableModelDatabaseName = targetDatabase.toLowerCase(Locale.ENGLISH);
340341
targetTreeModelDatabaseName =

0 commit comments

Comments
 (0)