You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/04/19 01:30:49 UTC

[iotdb] branch master updated: Remove mpp_mode property in iotdb-engine.properties (#5583)

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

qiaojialin 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 77a33e9795 Remove mpp_mode property in iotdb-engine.properties (#5583)
77a33e9795 is described below

commit 77a33e97953f0e9521de818927feb1bf626764ab
Author: Jackie Tien <ja...@gmail.com>
AuthorDate: Tue Apr 19 09:30:43 2022 +0800

    Remove mpp_mode property in iotdb-engine.properties (#5583)
---
 server/src/assembly/resources/conf/iotdb-engine.properties         | 3 ---
 server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 ----
 server/src/main/java/org/apache/iotdb/db/service/DataNode.java     | 2 ++
 3 files changed, 2 insertions(+), 7 deletions(-)

diff --git a/server/src/assembly/resources/conf/iotdb-engine.properties b/server/src/assembly/resources/conf/iotdb-engine.properties
index 76f0816963..beee02f3c2 100644
--- a/server/src/assembly/resources/conf/iotdb-engine.properties
+++ b/server/src/assembly/resources/conf/iotdb-engine.properties
@@ -27,9 +27,6 @@ rpc_address=0.0.0.0
 # Datatype: int
 rpc_port=6667
 
-# whether start data node in mpp mode
-# mpp_mode=false
-
 ####################
 ### Shuffle Configuration
 ####################
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
index 774990e978..8ecf55af49 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
@@ -167,10 +167,6 @@ public class IoTDBDescriptor {
           Integer.parseInt(
               properties.getProperty("rpc_port", Integer.toString(conf.getRpcPort()))));
 
-      conf.setMppMode(
-          Boolean.parseBoolean(
-              properties.getProperty("mpp_mode", Boolean.toString(conf.isMppMode()))));
-
       conf.setEnableInfluxDBRpcService(
           Boolean.parseBoolean(
               properties.getProperty(
diff --git a/server/src/main/java/org/apache/iotdb/db/service/DataNode.java b/server/src/main/java/org/apache/iotdb/db/service/DataNode.java
index a8a1de685d..4388cdddce 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/DataNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/DataNode.java
@@ -157,6 +157,8 @@ public class DataNode implements DataNodeMBean {
   }
 
   public void active() throws StartupException {
+    // set the mpp mode to true
+    IoTDBDescriptor.getInstance().getConfig().setMppMode(true);
     // start iotdb server first
     IoTDB.getInstance().active();