This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch flush
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/flush by this push:
new bbeadc50350 bishop
bbeadc50350 is described below
commit bbeadc50350e0d6faea26f58335a54939daef0b5
Author: Caideyipi <[email protected]>
AuthorDate: Thu Mar 26 12:21:15 2026 +0800
bishop
---
.../src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 3 ++-
.../src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java | 2 +-
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java
index bffe128f4c1..29cf56c80a3 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBFlushQueryIT.java
@@ -192,7 +192,8 @@ public class IoTDBFlushQueryIT {
statement.execute(
"FLUSH
root.noexist.nodatagroup1,root.notExistGroup1,root.notExistGroup2 on local");
} catch (SQLException sqe) {
- String expectedMsg = "500: Database
root.notExistGroup1,root.notExistGroup2 does not exist";
+ String expectedMsg =
+ "500: Database root.notExistGroup1,root.notExistGroup2 does not
exist on local";
sqe.printStackTrace();
assertTrue(sqe.getMessage().contains(expectedMsg));
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
index 72b637c42ef..2a1c21de040 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/StorageEngine.java
@@ -686,7 +686,7 @@ public class StorageEngine implements IService {
noExistDB.forEach(database -> sb.append(database).append(","));
return RpcUtils.getStatus(
TSStatusCode.DATABASE_NOT_EXIST,
- "Database " + sb.subSequence(0, sb.length() - 1) + " does not
exist");
+ "Database " + sb.subSequence(0, sb.length() - 1) + " does not
exist on local");
}
}
for (String databaseName : req.storageGroups) {
