From 911eb04594e893af0b4394eb405105b783775b2a Mon Sep 17 00:00:00 2001 From: caiconghui <55968745+caiconghui@users.noreply.github.com> Date: Sun, 26 Jul 2020 07:14:03 -0500 Subject: [PATCH] [Bug][UpdateDataQuota] Skip update used data quota for information_schema db and fix bug for wrong time interval for UpdateDbUsedDataQuotaDaemon (#4175) This PR is to skip update used data quota for information_schema db, and fix bug for wrong time interval for UpdateDbUsedDataQuotaDaemon. --- .../doris/transaction/UpdateDbUsedDataQuotaDaemon.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/transaction/UpdateDbUsedDataQuotaDaemon.java b/fe/fe-core/src/main/java/org/apache/doris/transaction/UpdateDbUsedDataQuotaDaemon.java index e8336a1da9..ffe073df87 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/transaction/UpdateDbUsedDataQuotaDaemon.java +++ b/fe/fe-core/src/main/java/org/apache/doris/transaction/UpdateDbUsedDataQuotaDaemon.java @@ -31,7 +31,7 @@ public class UpdateDbUsedDataQuotaDaemon extends MasterDaemon { private static final Logger LOG = LogManager.getLogger(UpdateDbUsedDataQuotaDaemon.class); public UpdateDbUsedDataQuotaDaemon() { - super("UPDATE_DB_USED_QUOTA", Config.db_used_data_quota_update_interval_secs); + super("UpdateDbUsedDataQuota", Config.db_used_data_quota_update_interval_secs * 1000); } @Override @@ -49,6 +49,9 @@ public class UpdateDbUsedDataQuotaDaemon extends MasterDaemon { LOG.warn("Database [" + dbId + "] doese not exist, skip to update database used data quota"); continue; } + if (db.isInfoSchemaDb()) { + continue; + } try { long usedDataQuotaBytes = db.getUsedDataQuotaWithLock(); globalTransactionMgr.updateDatabaseUsedQuotaData(dbId, usedDataQuotaBytes); @@ -56,7 +59,7 @@ public class UpdateDbUsedDataQuotaDaemon extends MasterDaemon { LOG.debug("Update database[{}] used data quota bytes : {}.", db.getFullName(), usedDataQuotaBytes); } } catch (AnalysisException e) { - LOG.warn("Update database[" + dbId + "] used data quota failed", e); + LOG.warn("Update database[" + db.getFullName() + "] used data quota failed", e); } } }