fix spell incorrect (#10127)
Co-authored-by: guanhongjun1 <guanhongjun@jd.com>
diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
index 96757ae..cd1b0d7 100644
--- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
+++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
@@ -579,7 +579,7 @@
String role,
AuthenticationDataSource authData) {
try {
- TenantInfo tenantInfo = pulsarResources.getTenatResources()
+ TenantInfo tenantInfo = pulsarResources.getTenantResources()
.get(path(POLICIES, tenantName))
.orElseThrow(() -> new RestException(Response.Status.NOT_FOUND, "Tenant does not exist"));
diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/PulsarResources.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/PulsarResources.java
index 894e33f9..48db47f 100644
--- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/PulsarResources.java
+++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/PulsarResources.java
@@ -31,7 +31,7 @@
public class PulsarResources {
public static final int DEFAULT_OPERATION_TIMEOUT_SEC = 30;
- private TenantResources tenatResources;
+ private TenantResources tenantResources;
private ClusterResources clusterResources;
private NamespaceResources namespaceResources;
private DynamicConfigurationResources dynamicConfigResources;
@@ -46,7 +46,7 @@
public PulsarResources(MetadataStoreExtended localMetadataStore, MetadataStoreExtended configurationMetadataStore,
int operationTimeoutSec) {
if (configurationMetadataStore != null) {
- tenatResources = new TenantResources(configurationMetadataStore, operationTimeoutSec);
+ tenantResources = new TenantResources(configurationMetadataStore, operationTimeoutSec);
clusterResources = new ClusterResources(configurationMetadataStore, operationTimeoutSec);
namespaceResources = new NamespaceResources(configurationMetadataStore, operationTimeoutSec);
}
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java
index 98d13f3..32b6b98 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java
@@ -263,7 +263,7 @@
(isClientAuthenticated(clientAppId)), clientAppId);
}
- TenantInfo tenantInfo = pulsar.getPulsarResources().getTenatResources().get(path(POLICIES, tenant))
+ TenantInfo tenantInfo = pulsar.getPulsarResources().getTenantResources().get(path(POLICIES, tenant))
.orElseThrow(() -> new RestException(Status.NOT_FOUND, "Tenant does not exist"));
if (pulsar.getConfiguration().isAuthenticationEnabled() && pulsar.getConfiguration().isAuthorizationEnabled()) {
@@ -319,7 +319,7 @@
protected void validateClusterForTenant(String tenant, String cluster) {
TenantInfo tenantInfo;
try {
- tenantInfo = pulsar().getPulsarResources().getTenatResources().get(path(POLICIES, tenant))
+ tenantInfo = pulsar().getPulsarResources().getTenantResources().get(path(POLICIES, tenant))
.orElseThrow(() -> new RestException(Status.NOT_FOUND, "Tenant does not exist"));
} catch (RestException e) {
log.warn("Failed to get tenant admin data for tenant {}", tenant);
@@ -876,7 +876,7 @@
}
protected TenantResources tenantResources() {
- return pulsar().getPulsarResources().getTenatResources();
+ return pulsar().getPulsarResources().getTenantResources();
}
protected ClusterResources clusterResources() {
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java
index 25a7169..cb9d136 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminTest.java
@@ -474,7 +474,7 @@
// clear caches to load data from metadata-store again
MetadataCacheImpl<TenantInfo> cache = (MetadataCacheImpl<TenantInfo>) pulsar.getPulsarResources()
- .getTenatResources().getCache();
+ .getTenantResources().getCache();
AbstractMetadataStore store = (AbstractMetadataStore) cache.getStore();
cache.invalidateAll();
store.invalidateAll();
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
index 69b3dfe..1d04934 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
@@ -288,7 +288,7 @@
});
// clear caches to load data from metadata-store again
MetadataCacheImpl<TenantInfo> tenantCache = (MetadataCacheImpl<TenantInfo>) pulsar.getPulsarResources()
- .getTenatResources().getCache();
+ .getTenantResources().getCache();
AbstractMetadataStore store = (AbstractMetadataStore) tenantCache.getStore();
tenantCache.invalidateAll();
store.invalidateAll();
diff --git a/pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/BrokerDiscoveryProvider.java b/pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/BrokerDiscoveryProvider.java
index f895792..4317763 100644
--- a/pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/BrokerDiscoveryProvider.java
+++ b/pulsar-discovery-service/src/main/java/org/apache/pulsar/discovery/service/BrokerDiscoveryProvider.java
@@ -140,7 +140,7 @@
// check namespace authorization
TenantInfo tenantInfo;
try {
- tenantInfo = service.getPulsarResources().getTenatResources()
+ tenantInfo = service.getPulsarResources().getTenantResources()
.get(path(POLICIES, topicName.getTenant()))
.orElseThrow(() -> new IllegalAccessException("Property does not exist"));
} catch (NotFoundException e) {
diff --git a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
index af25ebb..1601a98 100644
--- a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
+++ b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
@@ -301,7 +301,7 @@
// create tenant for function worker service
try {
NamedEntity.checkName(property);
- pulsarResources.getTenatResources().create(PolicyPath.path(POLICIES, property),
+ pulsarResources.getTenantResources().create(PolicyPath.path(POLICIES, property),
new TenantInfo(Sets.newHashSet(workerConfig.getSuperUserRoles()), Sets.newHashSet(cluster)));
LOG.info("Created property {} for function worker", property);
} catch (AlreadyExistsException e) {
