Skip to content

Commit

Permalink
fix uts.
Browse files Browse the repository at this point in the history
  • Loading branch information
leixm committed Dec 4, 2024
1 parent 940609e commit 2420531
Showing 1 changed file with 0 additions and 24 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,6 @@
public abstract class DynamicConfig {
private static final Logger LOG = LoggerFactory.getLogger(DynamicConfig.class);
protected volatile Map<String, String> configs = new HashMap<>();
protected volatile StorageQuota tenantStorageQuota = null;
protected volatile StorageQuota clusterStorageQuota = null;
protected volatile Map<String, Set<String>> tags = null;

public abstract DynamicConfig getParentLevelConfig();
Expand Down Expand Up @@ -96,17 +94,6 @@ public <T> T formatValue(
}

public StorageQuota getTenantStorageQuota() {
if (tenantStorageQuota == null) {
synchronized (DynamicConfig.class) {
if (tenantStorageQuota == null) {
tenantStorageQuota = currentTenantQuota();
}
}
}
return tenantStorageQuota;
}

protected StorageQuota currentTenantQuota() {
return new StorageQuota(
getValue(
CelebornConf.QUOTA_DISK_BYTES_WRITTEN().key(),
Expand Down Expand Up @@ -183,17 +170,6 @@ public WorkerTagsMeta getWorkerTagsMeta() {
}

public StorageQuota getClusterStorageQuota() {
if (clusterStorageQuota == null) {
synchronized (DynamicConfig.class) {
if (clusterStorageQuota == null) {
clusterStorageQuota = currentClusterQuota();
}
}
}
return clusterStorageQuota;
}

protected StorageQuota currentClusterQuota() {
return new StorageQuota(
getValue(
CelebornConf.QUOTA_CLUSTER_DISK_BYTES_WRITTEN().key(),
Expand Down

0 comments on commit 2420531

Please sign in to comment.