You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2023/01/31 13:04:29 UTC
[iotdb] branch geely_car updated: add isAllPartitionsExist judgement
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch geely_car
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/geely_car by this push:
new 35355c351b add isAllPartitionsExist judgement
35355c351b is described below
commit 35355c351b6128ab0b2cbe54103c8503a101ecfe
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Tue Jan 31 21:04:15 2023 +0800
add isAllPartitionsExist judgement
---
.../apache/iotdb/confignode/manager/partition/PartitionManager.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
index fafb478be7..d081d10020 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionManager.java
@@ -318,7 +318,11 @@ public class PartitionManager {
}
}
- return (DataPartitionResp) getDataPartition(req);
+ resp = (DataPartitionResp) getDataPartition(req);
+ if (!resp.isAllPartitionsExist()) {
+ LOGGER.error("Not all partition exist in DataPartitionResp!");
+ }
+ return resp;
}
// ======================================================