This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new e7aa0380d39 Fixed the NPE of schema region database for
GeneralRegionAttributeSecurityService
e7aa0380d39 is described below
commit e7aa0380d39bd5d7b9f248d7062991300703a2a0
Author: Caideyipi <[email protected]>
AuthorDate: Mon Oct 28 12:24:08 2024 +0800
Fixed the NPE of schema region database for
GeneralRegionAttributeSecurityService
---
.../attribute/update/GeneralRegionAttributeSecurityService.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/GeneralRegionAttributeSecurityService.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/GeneralRegionAttributeSecurityService.java
index 58dbb0142f8..cf1a0395889 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/GeneralRegionAttributeSecurityService.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/update/GeneralRegionAttributeSecurityService.java
@@ -94,15 +94,15 @@ public class GeneralRegionAttributeSecurityService
implements IService {
public void startBroadcast(final ISchemaRegion schemaRegion) {
if (schemaRegion instanceof SchemaRegionMemoryImpl) {
- regionLeaders.add(schemaRegion);
regionId2DatabaseMap.put(
schemaRegion.getSchemaRegionId(),
schemaRegion.getDatabaseFullPath().substring(5));
+ regionLeaders.add(schemaRegion);
}
}
public void stopBroadcast(final ISchemaRegion schemaRegion) {
regionLeaders.remove(schemaRegion);
- regionId2DatabaseMap.remove(schemaRegion.getSchemaRegionId());
+ // Reserve the database info for concurrency simplicity
}
public void notifyBroadCast() {
