You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2023/01/09 11:15:27 UTC

[iotdb] branch jira5389 created (now e59db0ef93)

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a change to branch jira5389
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at e59db0ef93 finish

This branch includes the following new commits:

     new e59db0ef93 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 ta...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch jira5389
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit e59db0ef933fa09f58a4ad0faee15cd964264768
Author: OneSizeFitQuorum <ta...@apache.org>
AuthorDate: Mon Jan 9 19:15:11 2023 +0800

    finish
    
    Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
 .../src/main/java/org/apache/iotdb/db/conf/IoTDBStartCheck.java   | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBStartCheck.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBStartCheck.java
index bc0bd52949..50e4a85044 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBStartCheck.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBStartCheck.java
@@ -107,6 +107,7 @@ public class IoTDBStartCheck {
     constantParamValueTable.put(
         TIME_ENCODER_KEY, TSFileDescriptor.getInstance().getConfig()::getTimeEncoder);
   }
+
   // endregion
   // region params don't need checking and can be updated
   private static final String INTERNAL_ADDRESS = "dn_internal_address";
@@ -131,6 +132,7 @@ public class IoTDBStartCheck {
     variableParamValueTable.put(
         DATA_REGION_CONSENSUS_PORT, () -> String.valueOf(config.getDataRegionConsensusPort()));
   }
+
   // endregion
   // region params don't need checking, determined by the system
   private static final String IOTDB_VERSION_STRING = "iotdb_version";
@@ -304,6 +306,12 @@ public class IoTDBStartCheck {
         systemProperties.forEach((k, v) -> properties.setProperty(k, v.get()));
         properties.store(outputStream, SYSTEM_PROPERTIES_STRING);
       }
+      if (config.isClusterMode()
+          && config.getDataRegionConsensusProtocolClass().equals(ConsensusFactory.IOT_CONSENSUS)
+          && config.getWalMode().equals(WALMode.DISABLE)) {
+        throw new ConfigurationException(
+            "Configuring the WALMode as disable is not supported under IoTConsensus");
+      }
     } else {
       // check whether upgrading from <=v0.9
       if (!properties.containsKey(IOTDB_VERSION_STRING)) {