You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2023/05/30 09:28:59 UTC
[iotdb] branch seriesslot-comptivity created (now 4517942930a)
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch seriesslot-comptivity
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 4517942930a Finish
This branch includes the following new commits:
new 4517942930a Finish
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: Finish
Posted by yo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch seriesslot-comptivity
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4517942930ace62239a23822409186c54e30d8c9
Author: YongzaoDan <53...@qq.com>
AuthorDate: Tue May 30 17:28:48 2023 +0800
Finish
---
.../confignode/conf/SystemPropertiesUtils.java | 42 +++++++++++-----------
1 file changed, 21 insertions(+), 21 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/conf/SystemPropertiesUtils.java b/confignode/src/main/java/org/apache/iotdb/confignode/conf/SystemPropertiesUtils.java
index 6847e7dc937..b5af67d75d7 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/conf/SystemPropertiesUtils.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/conf/SystemPropertiesUtils.java
@@ -124,11 +124,11 @@ public class SystemPropertiesUtils {
needReWrite = true;
} else if (!configNodeConsensusProtocolClass.equals(
conf.getConfigNodeConsensusProtocolClass())) {
- throw new ConfigurationException(
- "config_node_consensus_protocol_class",
+ LOGGER.warn(
+ "[SystemProperties] The parameter \"config_node_consensus_protocol_class\" can't be modified after first startup. Your configuration: {} will be forced update to: {}",
conf.getConfigNodeConsensusProtocolClass(),
- configNodeConsensusProtocolClass,
- "config_node_consensus_protocol_class can't be modified after first startup");
+ configNodeConsensusProtocolClass);
+ conf.setConfigNodeConsensusProtocolClass(configNodeConsensusProtocolClass);
}
String dataRegionConsensusProtocolClass =
@@ -137,11 +137,11 @@ public class SystemPropertiesUtils {
needReWrite = true;
} else if (!dataRegionConsensusProtocolClass.equals(
conf.getDataRegionConsensusProtocolClass())) {
- throw new ConfigurationException(
- "data_region_consensus_protocol_class",
+ LOGGER.warn(
+ "[SystemProperties] The parameter \"data_region_consensus_protocol_class\" can't be modified after first startup. Your configuration: {} will be forced update to: {}",
conf.getDataRegionConsensusProtocolClass(),
- dataRegionConsensusProtocolClass,
- "data_region_consensus_protocol_class can't be modified after first startup");
+ dataRegionConsensusProtocolClass);
+ conf.setDataRegionConsensusProtocolClass(dataRegionConsensusProtocolClass);
}
String schemaRegionConsensusProtocolClass =
@@ -150,11 +150,11 @@ public class SystemPropertiesUtils {
needReWrite = true;
} else if (!schemaRegionConsensusProtocolClass.equals(
conf.getSchemaRegionConsensusProtocolClass())) {
- throw new ConfigurationException(
- "schema_region_consensus_protocol_class",
+ LOGGER.warn(
+ "[SystemProperties] The parameter \"schema_region_consensus_protocol_class\" can't be modified after first startup. Your configuration: {} will be forced update to: {}",
conf.getSchemaRegionConsensusProtocolClass(),
- schemaRegionConsensusProtocolClass,
- "schema_region_consensus_protocol_class can't be modified after first startup");
+ schemaRegionConsensusProtocolClass);
+ conf.setSchemaRegionConsensusProtocolClass(schemaRegionConsensusProtocolClass);
}
// PartitionSlot configuration
@@ -164,11 +164,11 @@ public class SystemPropertiesUtils {
int seriesPartitionSlotNum =
Integer.parseInt(systemProperties.getProperty("series_partition_slot_num"));
if (seriesPartitionSlotNum != conf.getSeriesSlotNum()) {
- throw new ConfigurationException(
- "series_partition_slot_num",
- String.valueOf(conf.getSeriesSlotNum()),
- String.valueOf(seriesPartitionSlotNum),
- "series_partition_slot_num can't be modified after first startup");
+ LOGGER.warn(
+ "[SystemProperties] The parameter \"series_slot_num\" can't be modified after first startup. Your configuration: {} will be forced update to: {}",
+ conf.getSeriesSlotNum(),
+ seriesPartitionSlotNum);
+ conf.setSeriesSlotNum(seriesPartitionSlotNum);
}
}
@@ -178,11 +178,11 @@ public class SystemPropertiesUtils {
needReWrite = true;
} else if (!Objects.equals(
seriesPartitionSlotExecutorClass, conf.getSeriesPartitionExecutorClass())) {
- throw new ConfigurationException(
- "series_partition_executor_class",
+ LOGGER.warn(
+ "[SystemProperties] The parameter \"seriesPartitionSlotExecutorClass\" can't be modified after first startup. Your configuration: {} will be forced update to: {}",
conf.getSeriesPartitionExecutorClass(),
- seriesPartitionSlotExecutorClass,
- "series_partition_executor_class can't be modified after first startup");
+ seriesPartitionSlotExecutorClass);
+ conf.setSeriesPartitionExecutorClass(seriesPartitionSlotExecutorClass);
}
if (needReWrite) {