This is an automated email from the ASF dual-hosted git repository. jianyun pushed a commit to branch rocksdb/dev in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 399452f6cb7e229a5551b83e237d93c2fc891090 Author: lisijia <[email protected]> AuthorDate: Thu Mar 10 16:53:54 2022 +0800 Fix a bug where the result is invalid --- .../iotdb/db/metadata/rocksdb/GetBelongedToSpecifiedType.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/GetBelongedToSpecifiedType.java b/server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/GetBelongedToSpecifiedType.java index 61535ac..023aaeb 100644 --- a/server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/GetBelongedToSpecifiedType.java +++ b/server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/GetBelongedToSpecifiedType.java @@ -22,12 +22,13 @@ import org.apache.iotdb.db.exception.metadata.IllegalPathException; import org.apache.iotdb.db.metadata.path.PartialPath; import org.apache.iotdb.db.metadata.utils.MetaUtils; +import org.rocksdb.RocksDBException; + import java.util.ArrayList; import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.regex.Pattern; -import org.rocksdb.RocksDBException; import static org.apache.iotdb.db.conf.IoTDBConstant.MULTI_LEVEL_PATH_WILDCARD; import static org.apache.iotdb.db.conf.IoTDBConstant.ONE_LEVEL_PATH_WILDCARD; @@ -76,10 +77,10 @@ public class GetBelongedToSpecifiedType { contextNodes.add(nodes[idx]); String innerName = RocksDBUtils.convertPartialPathToInnerByNodes( - contextNodes.toArray(new String[0]), contextNodes.size(), nodeType); + contextNodes.toArray(new String[0]), contextNodes.size() - 1, nodeType); byte[] queryResult = readWriteHandler.get(null, innerName.getBytes()); if (queryResult != null) { - allResult.add(new PartialPath(new String(queryResult))); + allResult.add(new PartialPath(RocksDBUtils.concatNodesName(nodes, 0, idx))); } }
