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 a0a4e006dc [IOTDB-3895]Log each parameter when starting IoTDB (#6965)
a0a4e006dc is described below
commit a0a4e006dc44710c4b7e5bd46c399bfa11dfebbf
Author: ly <[email protected]>
AuthorDate: Tue Aug 16 21:51:07 2022 +0800
[IOTDB-3895]Log each parameter when starting IoTDB (#6965)
---
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 35 ++++++++++++++++++++++
.../java/org/apache/iotdb/db/service/DataNode.java | 1 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 1 +
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 1 +
4 files changed, 38 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index a5de2f940f..ddedb1b676 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -47,6 +47,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
+import java.lang.reflect.Field;
+import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.TimeUnit;
@@ -3063,4 +3065,37 @@ public class IoTDBConfig {
public void setThrottleDownThreshold(long throttleDownThreshold) {
this.throttleDownThreshold = throttleDownThreshold;
}
+
+ public String getConfigMessage() {
+ String configMessage = "";
+ String configContent;
+ String[] notShowArray = {
+ "NODE_NAME_MATCHER",
+ "PARTIAL_NODE_MATCHER",
+ "STORAGE_GROUP_MATCHER",
+ "STORAGE_GROUP_PATTERN",
+ "NODE_MATCHER",
+ "NODE_PATTERN"
+ };
+ List<String> notShowStrings = Arrays.asList(notShowArray);
+ for (Field configField : IoTDBConfig.class.getDeclaredFields()) {
+ try {
+ String configFieldString = configField.getName();
+ if (notShowStrings.contains(configFieldString)) {
+ continue;
+ }
+ String configType = configField.getGenericType().getTypeName();
+ if (configType.contains("java.lang.String[]")) {
+ String[] configList = (String[]) configField.get(this);
+ configContent = Arrays.asList(configList).toString();
+ } else {
+ configContent = configField.get(this).toString();
+ }
+ configMessage = configMessage + configField.getName() + "=" +
configContent + "; ";
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ return configMessage;
+ }
}
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 9053f16f01..2d794003b2 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
@@ -129,6 +129,7 @@ public class DataNode implements DataNodeMBean {
active();
// setup rpc service
setUpRPCService();
+ logger.info("IoTDB configuration: " + config.getConfigMessage());
logger.info("Congratulation, IoTDB DataNode is set up successfully. Now,
enjoy yourself!");
} catch (StartupException e) {
logger.error("Fail to start server", e);
diff --git a/server/src/main/java/org/apache/iotdb/db/service/IoTDB.java
b/server/src/main/java/org/apache/iotdb/db/service/IoTDB.java
index a12aecd456..ff41b8e2d4 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/IoTDB.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/IoTDB.java
@@ -194,6 +194,7 @@ public class IoTDB implements IoTDBMBean {
// start reporter
MetricService.getInstance().startAllReporter();
+ logger.info("IoTDB configuration: " + config.getConfigMessage());
logger.info("Congratulation, IoTDB is set up successfully. Now, enjoy
yourself!");
}
diff --git a/server/src/main/java/org/apache/iotdb/db/service/NewIoTDB.java
b/server/src/main/java/org/apache/iotdb/db/service/NewIoTDB.java
index bddb750199..a0ceaade07 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/NewIoTDB.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/NewIoTDB.java
@@ -177,6 +177,7 @@ public class NewIoTDB implements NewIoTDBMBean {
// start reporter
MetricService.getInstance().startAllReporter();
+ logger.info("IoTDB configuration: " + config.getConfigMessage());
logger.info("Congratulation, IoTDB is set up successfully. Now, enjoy
yourself!");
}