This is an automated email from the ASF dual-hosted git repository.
tanxinyu 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 b2726a578f3 decrease default direct buffer size in IT config (#13361)
b2726a578f3 is described below
commit b2726a578f33794fab6cccfa060c5549c2e24ef5
Author: shuwenwei <[email protected]>
AuthorDate: Sat Aug 31 23:06:53 2024 +0800
decrease default direct buffer size in IT config (#13361)
---
.../main/java/org/apache/iotdb/it/env/cluster/ClusterConstant.java | 7 +++++++
.../org/apache/iotdb/it/env/cluster/node/ConfigNodeWrapper.java | 2 ++
.../java/org/apache/iotdb/it/env/cluster/node/DataNodeWrapper.java | 6 ++++++
3 files changed, 15 insertions(+)
diff --git
a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ClusterConstant.java
b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ClusterConstant.java
index 12af0d025f7..e685dd74ed2 100644
---
a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ClusterConstant.java
+++
b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ClusterConstant.java
@@ -171,6 +171,13 @@ public class ClusterConstant {
"dn_join_cluster_retry_interval_ms";
public static final String DN_CONNECTION_TIMEOUT_MS =
"dn_connection_timeout_ms";
public static final String DN_METRIC_INTERNAL_REPORTER_TYPE =
"dn_metric_internal_reporter_type";
+ public static final String CONFIG_NODE_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX =
+ "config_node_ratis_log_appender_buffer_size_max";
+ public static final String WAL_BUFFER_SIZE_IN_BYTE =
"wal_buffer_size_in_byte";
+ public static final String SCHEMA_REGION_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX =
+ "schema_region_ratis_log_appender_buffer_size_max";
+ public static final String DATA_REGION_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX =
+ "data_region_ratis_log_appender_buffer_size_max";
// Paths
public static final String USER_DIR = "user.dir";
diff --git
a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/ConfigNodeWrapper.java
b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/ConfigNodeWrapper.java
index a93c54c52b8..a509790ad07 100644
---
a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/ConfigNodeWrapper.java
+++
b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/ConfigNodeWrapper.java
@@ -38,6 +38,7 @@ import static
org.apache.iotdb.it.env.cluster.ClusterConstant.CONFIG_NODE_CONSEN
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.CONFIG_NODE_INIT_HEAP_SIZE;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.CONFIG_NODE_MAX_DIRECT_MEMORY_SIZE;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.CONFIG_NODE_MAX_HEAP_SIZE;
+import static
org.apache.iotdb.it.env.cluster.ClusterConstant.CONFIG_NODE_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DATA_REGION_CONSENSUS_PROTOCOL_CLASS;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DATA_REPLICATION_FACTOR;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DEFAULT_CONFIG_NODE_COMMON_PROPERTIES;
@@ -160,6 +161,7 @@ public class ConfigNodeWrapper extends AbstractNodeWrapper {
IoTDBConstant.CN_CONSENSUS_PORT, String.valueOf(this.consensusPort));
mutableNodeProperties.setProperty(
IoTDBConstant.CN_METRIC_PROMETHEUS_REPORTER_PORT,
String.valueOf(super.getMetricPort()));
+
mutableNodeProperties.setProperty(CONFIG_NODE_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX,
"8388608");
}
@Override
diff --git
a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/DataNodeWrapper.java
b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/DataNodeWrapper.java
index 647bd9b9fa0..cb7e840af63 100644
---
a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/DataNodeWrapper.java
+++
b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/DataNodeWrapper.java
@@ -36,6 +36,7 @@ import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DATANODE_MAX_DIREC
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DATANODE_MAX_HEAP_SIZE;
import static org.apache.iotdb.it.env.cluster.ClusterConstant.DATA_NODE_NAME;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DATA_REGION_CONSENSUS_PROTOCOL_CLASS;
+import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DATA_REGION_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DATA_REPLICATION_FACTOR;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DEFAULT_DATA_NODE_COMMON_PROPERTIES;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.DEFAULT_DATA_NODE_PROPERTIES;
@@ -61,9 +62,11 @@ import static
org.apache.iotdb.it.env.cluster.ClusterConstant.PAGE_SIZE_IN_BYTE;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.PIPE_AIR_GAP_RECEIVER_PORT;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.REST_SERVICE_PORT;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS;
+import static
org.apache.iotdb.it.env.cluster.ClusterConstant.SCHEMA_REGION_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX;
import static
org.apache.iotdb.it.env.cluster.ClusterConstant.SCHEMA_REPLICATION_FACTOR;
import static org.apache.iotdb.it.env.cluster.ClusterConstant.TARGET;
import static org.apache.iotdb.it.env.cluster.ClusterConstant.USER_DIR;
+import static
org.apache.iotdb.it.env.cluster.ClusterConstant.WAL_BUFFER_SIZE_IN_BYTE;
public class DataNodeWrapper extends AbstractNodeWrapper {
private int mppDataExchangePort;
@@ -203,6 +206,9 @@ public class DataNodeWrapper extends AbstractNodeWrapper {
DN_DATA_REGION_CONSENSUS_PORT,
String.valueOf(this.dataRegionConsensusPort));
mutableNodeProperties.setProperty(
DN_SCHEMA_REGION_CONSENSUS_PORT,
String.valueOf(this.schemaRegionConsensusPort));
+ mutableNodeProperties.setProperty(WAL_BUFFER_SIZE_IN_BYTE, "16777216");
+
mutableNodeProperties.setProperty(SCHEMA_REGION_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX,
"8388608");
+
mutableNodeProperties.setProperty(DATA_REGION_RATIS_LOG_APPENDER_BUFFER_SIZE_MAX,
"8388608");
}
@Override
