This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new f0c51919992 [log](tablet invert) add preconditition check failed log
(#26770) (#27171)
f0c51919992 is described below
commit f0c51919992e75c3a0c5fb5d7ea1f055fc9a8b87
Author: yujun <[email protected]>
AuthorDate: Fri Nov 17 21:50:07 2023 +0800
[log](tablet invert) add preconditition check failed log (#26770) (#27171)
---
.../org/apache/doris/catalog/TabletInvertedIndex.java | 15 ++++++++++-----
1 file changed, 10 insertions(+), 5 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java
index 39818d52bc6..2d51c2a89a5 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/TabletInvertedIndex.java
@@ -142,7 +142,8 @@ public class TabletInvertedIndex {
// traverse replicas in meta with this backend
replicaMetaWithBackend.entrySet().parallelStream().forEach(entry -> {
long tabletId = entry.getKey();
-
Preconditions.checkState(tabletMetaMap.containsKey(tabletId));
+
Preconditions.checkState(tabletMetaMap.containsKey(tabletId),
+ "tablet " + tabletId + " not exists, backend "
+ backendId);
TabletMeta tabletMeta = tabletMetaMap.get(tabletId);
if (backendTablets.containsKey(tabletId)) {
@@ -553,7 +554,9 @@ public class TabletInvertedIndex {
public void addReplica(long tabletId, Replica replica) {
long stamp = writeLock();
try {
- Preconditions.checkState(tabletMetaMap.containsKey(tabletId));
+ Preconditions.checkState(tabletMetaMap.containsKey(tabletId),
+ "tablet " + tabletId + " not exists, replica " +
replica.getId()
+ + ", backend " + replica.getBackendId());
replicaMetaTable.put(tabletId, replica.getBackendId(), replica);
replicaToTabletMap.put(replica.getId(), tabletId);
backingReplicaMetaTable.put(replica.getBackendId(), tabletId,
replica);
@@ -567,7 +570,8 @@ public class TabletInvertedIndex {
public void deleteReplica(long tabletId, long backendId) {
long stamp = writeLock();
try {
- Preconditions.checkState(tabletMetaMap.containsKey(tabletId));
+ Preconditions.checkState(tabletMetaMap.containsKey(tabletId),
+ "tablet " + tabletId + " not exists, backend " +
backendId);
if (replicaMetaTable.containsRow(tabletId)) {
Replica replica = replicaMetaTable.remove(tabletId, backendId);
replicaToTabletMap.remove(replica.getId());
@@ -588,7 +592,8 @@ public class TabletInvertedIndex {
public Replica getReplica(long tabletId, long backendId) {
long stamp = readLock();
try {
- Preconditions.checkState(tabletMetaMap.containsKey(tabletId),
tabletId);
+ Preconditions.checkState(tabletMetaMap.containsKey(tabletId),
+ "tablet " + tabletId + " not exists, backend " +
backendId);
return replicaMetaTable.get(tabletId, backendId);
} finally {
readUnlock(stamp);
@@ -731,7 +736,7 @@ public class TabletInvertedIndex {
Preconditions.checkNotNull(tabletMeta, "invalid tablet " +
tabletId);
Preconditions.checkState(
!Env.getCurrentColocateIndex().isColocateTable(tabletMeta.getTableId()),
- "should not be the colocate table");
+ "table " + tabletMeta.getTableId() + " should not
be the colocate table");
TStorageMedium medium = tabletMeta.getStorageMedium();
Table<Long, Long, Map<Long, Long>> partitionReplicasInfo =
partitionReplicasInfoMaps.get(medium);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
