This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a commit to branch grrrrrr
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/grrrrrr by this push:
new 6d5d0c4efed Fix
6d5d0c4efed is described below
commit 6d5d0c4efed8a344661a1cc13bdaf0e275838b10
Author: Caideyipi <[email protected]>
AuthorDate: Fri May 15 11:59:54 2026 +0800
Fix
---
.../treemodel/auto/basic/IoTDBPipeReceiverAutoCreateDisabledIT.java | 3 +++
.../iotdb/db/pipe/sink/protocol/airgap/IoTDBDataRegionAirGapSink.java | 4 ++--
.../db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java | 2 +-
.../db/pipe/sink/protocol/thrift/sync/IoTDBDataRegionSyncSink.java | 2 +-
4 files changed, 7 insertions(+), 4 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeReceiverAutoCreateDisabledIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeReceiverAutoCreateDisabledIT.java
index 4fdfe746659..d749530c7ac 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeReceiverAutoCreateDisabledIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeReceiverAutoCreateDisabledIT.java
@@ -83,6 +83,8 @@ public class IoTDBPipeReceiverAutoCreateDisabledIT extends
AbstractPipeDualTreeM
+ "with sink ('sink'='iotdb-thrift-sink',
'sink.node-urls'='%s');",
receiverEnv.getDataNodeWrapper(0).getIpAndPortString());
final String createDatabaseSql = "create database root.test.sg;";
+ final String createSecondDatabaseSql =
+ "create database
root.test.ABCDEFGHIJKLMNOPQRSTUVWXYZ_abcdefghijklmnopqrstuvwxyz1;";
final String createFirstTimeSeriesSql =
"create timeseries
root.test.sg.`1~!@#$%^&*()_+=:'\"/|[]{}`.`~!@#$%^&*()_+=:'\"/|[]{}` float;";
final String insertFirstSql =
@@ -105,6 +107,7 @@ public class IoTDBPipeReceiverAutoCreateDisabledIT extends
AbstractPipeDualTreeM
statement.execute(createFirstTimeSeriesSql);
statement.execute(insertFirstSql);
final QueryResult firstQueryResult = queryForResult(statement,
firstSelectSql);
+ statement.execute(createSecondDatabaseSql);
statement.execute(createSecondTimeSeriesSql);
statement.execute(insertSecondSql);
final QueryResult secondQueryResult = queryForResult(statement,
secondSelectSql);
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/airgap/IoTDBDataRegionAirGapSink.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/airgap/IoTDBDataRegionAirGapSink.java
index 7f904324bbb..64124c56256 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/airgap/IoTDBDataRegionAirGapSink.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/airgap/IoTDBDataRegionAirGapSink.java
@@ -341,7 +341,7 @@ public class IoTDBDataRegionAirGapSink extends
IoTDBDataNodeAirGapSink {
tsFile.length(),
pipeTsFileInsertionEvent.isTableModelEvent()
? pipeTsFileInsertionEvent.getTableModelDatabaseName()
- : null))) {
+ : pipeTsFileInsertionEvent.getTreeModelDatabaseName()))) {
receiverStatusHandler.handle(
new
TSStatus(TSStatusCode.PIPE_RECEIVER_USER_CONFLICT_EXCEPTION.getStatusCode())
.setMessage(errorMessage),
@@ -362,7 +362,7 @@ public class IoTDBDataRegionAirGapSink extends
IoTDBDataNodeAirGapSink {
tsFile.length(),
pipeTsFileInsertionEvent.isTableModelEvent()
? pipeTsFileInsertionEvent.getTableModelDatabaseName()
- : null))) {
+ : pipeTsFileInsertionEvent.getTreeModelDatabaseName()))) {
receiverStatusHandler.handle(
new
TSStatus(TSStatusCode.PIPE_RECEIVER_USER_CONFLICT_EXCEPTION.getStatusCode())
.setMessage(errorMessage),
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java
index 554c6c43dfb..97e9309a435 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java
@@ -423,7 +423,7 @@ public class IoTDBDataRegionAsyncSink extends IoTDBSink {
&& clientManager.supportModsIfIsDataNodeReceiver(),
pipeTsFileInsertionEvent.isTableModelEvent()
? pipeTsFileInsertionEvent.getTableModelDatabaseName()
- : null);
+ : pipeTsFileInsertionEvent.getTreeModelDatabaseName());
transfer(pipeTransferTsFileHandler);
return true;
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/sync/IoTDBDataRegionSyncSink.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/sync/IoTDBDataRegionSyncSink.java
index e8c4420861c..4309e5dae4e 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/sync/IoTDBDataRegionSyncSink.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/sync/IoTDBDataRegionSyncSink.java
@@ -499,7 +499,7 @@ public class IoTDBDataRegionSyncSink extends
IoTDBDataNodeSyncSink {
pipeTsFileInsertionEvent.isWithMod() ?
pipeTsFileInsertionEvent.getModFile() : null,
pipeTsFileInsertionEvent.isTableModelEvent()
? pipeTsFileInsertionEvent.getTableModelDatabaseName()
- : null);
+ : pipeTsFileInsertionEvent.getTreeModelDatabaseName());
} finally {
pipeTsFileInsertionEvent.decreaseReferenceCount(
IoTDBDataRegionSyncSink.class.getName(), false);
