From 049f72a2f439c3582027e9e370b0f307b9483f4e Mon Sep 17 00:00:00 2001 From: Caideyipi <87789683+Caideyipi@users.noreply.github.com> Date: Mon, 21 Oct 2024 11:29:10 +0800 Subject: [PATCH] Fix --- .../apache/iotdb/db/schemaengine/table/DataNodeTableCache.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java index 9b8ed5ddbdf1..4ada1b6b95e0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java @@ -369,12 +369,14 @@ private Pair checkTableExistenceOnGivenPath( for (final Map.Entry> dbEntry : tableMap.entrySet()) { final String database = dbEntry.getKey(); if (!(path.startsWith(database, dbStartIndex) + && path.length() > dbStartIndex + database.length() && path.charAt(dbStartIndex + database.length()) == PATH_SEPARATOR)) { continue; } final int tableStartIndex = dbStartIndex + database.length() + 1; for (final String tableName : dbEntry.getValue().keySet()) { if (path.startsWith(tableName, tableStartIndex) + && path.length() > tableStartIndex + tableName.length() && path.charAt(tableStartIndex + tableName.length()) == PATH_SEPARATOR) { return new Pair<>(database, tableName); }