You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2023/01/29 08:13:38 UTC
[iotdb] 01/03: add error log when target partition list is emtpy
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch geely_1.0.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7169d47fe6dcfec51c00e9d3fac9f82089551eae
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Fri Jan 13 21:00:57 2023 +0800
add error log when target partition list is emtpy
---
.../java/org/apache/iotdb/commons/partition/DataPartition.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java b/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
index ffdc345e1d..73d2a36780 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
@@ -23,6 +23,9 @@ import org.apache.iotdb.common.rpc.thrift.TSeriesPartitionSlot;
import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
import org.apache.iotdb.commons.utils.PathUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
@@ -33,6 +36,7 @@ import java.util.stream.Collectors;
// TODO: Remove this class
public class DataPartition extends Partition {
+ private static final Logger logger = LoggerFactory.getLogger(DataPartition.class);
public static final TRegionReplicaSet NOT_ASSIGNED = new TRegionReplicaSet();
// Map<StorageGroup, Map<TSeriesPartitionSlot, Map<TTimePartitionSlot, List<TRegionMessage>>>>
private Map<String, Map<TSeriesPartitionSlot, Map<TTimePartitionSlot, List<TRegionReplicaSet>>>>
@@ -99,6 +103,11 @@ public class DataPartition extends Partition {
for (TTimePartitionSlot timePartitionSlot : timePartitionSlotList) {
List<TRegionReplicaSet> targetRegionList = slotReplicaSetMap.get(timePartitionSlot);
if (targetRegionList == null || targetRegionList.size() == 0) {
+ logger.error(
+ "met error when calculating partition for writing. device: {}, target timePartitionSlotList: {}, dataPartitionMap: {}",
+ deviceName,
+ timePartitionSlotList,
+ dataPartitionMap);
throw new RuntimeException(
String.format(
"targetRegionList is empty. device: %s, timeSlot: %s",