database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Fix](cooldown) Fix incorrect judgement of isDropTableOrPartition (#21084)

Browse Source
This commit is contained in:
plat1ko
2023-06-21 23:00:58 +08:00
committed by GitHub
parent 2ce8cfbebd
commit e060ffab96
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/master/ReportHandler.java
View File

@ -853,13 +853,12 @@ public class ReportHandler extends Daemon {
TTablet backendTablet = backendTablets.get(tabletId);
TTabletInfo backendTabletInfo = backendTablet.getTabletInfos().get(0);
boolean needDelete = false;
TabletMeta tabletMeta = null;
TabletMeta tabletMeta = invertedIndex.getTabletMeta(tabletId);
LOG.debug("process tablet [{}], backend[{}]", tabletId, backendId);
if (!tabletFoundInMeta.contains(tabletId)) {
if (isBackendReplicaHealthy(backendTabletInfo)) {
// if this tablet meta is still in invertedIndex. try to add it.
// if add failed. delete this tablet from backend.
tabletMeta = invertedIndex.getTabletMeta(tabletId);
if (tabletMeta != null && addReplica(tabletId, tabletMeta, backendTabletInfo, backendId)) {
// update counter
++addToMetaCounter;
@ -876,6 +875,7 @@ public class ReportHandler extends Daemon {
if (needDelete) {
// drop replica
long replicaId = backendTabletInfo.getReplicaId();
// If no such tablet meta, this indicates that the tablet belongs to a dropped table or partition
boolean isDropTableOrPartition = tabletMeta == null;
DropReplicaTask task = new DropReplicaTask(backendId, tabletId, replicaId,
backendTabletInfo.getSchemaHash(), isDropTableOrPartition);