This is an automated email from the ASF dual-hosted git repository.
jt2594838 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 7d90a2e5c51 Use graceful shutdown in subscription recovery IT and
remove parser limits from template (#18994)
7d90a2e5c51 is described below
commit 7d90a2e5c518ab7d27b85b0060afd69a03878d7e
Author: Caideyipi <[email protected]>
AuthorDate: Fri Oct 23 12:18:36 2026 +0800
Use graceful shutdown in subscription recovery IT and remove parser limits
from template (#18994)
* Use graceful restart in subscription recovery IT
* Remove TsFile parser limits from default template
---
.../IoTDBConsensusSubscriptionRecoveryTableIT.java | 10 ++++------
.../resources/conf/iotdb-system.properties.template | 13 -------------
2 files changed, 4 insertions(+), 19 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionRecoveryTableIT.java
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionRecoveryTableIT.java
index 3df498340be..c7c7d482b4b 100644
---
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionRecoveryTableIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/consensus/local/tablemodel/IoTDBConsensusSubscriptionRecoveryTableIT.java
@@ -51,9 +51,7 @@ public class IoTDBConsensusSubscriptionRecoveryTableIT
@Override
@Before
public void setUp() throws Exception {
- // Isolate subscription recovery from data loss caused by ASYNC WAL during
a forced shutdown.
- EnvFactory.getEnv().getConfig().getCommonConfig().setWalMode("SYNC");
- // Persist each acknowledged batch before killing the servers.
+ // Persist each acknowledged batch before restarting the servers.
final Properties properties = new Properties();
properties.setProperty("subscription_consensus_commit_persist_interval",
"1");
properties.setProperty("subscription_consensus_commit_fsync_enabled",
"true");
@@ -95,8 +93,8 @@ public class IoTDBConsensusSubscriptionRecoveryTableIT
ConsensusSubscriptionTableITSupport.insertRows(
ids.getDatabase(), tableName, 2_000L, 64, true);
- EnvFactory.getEnv().shutdownForciblyAllDataNodes();
- EnvFactory.getEnv().shutdownForciblyAllConfigNodes();
+ EnvFactory.getEnv().shutdownAllDataNodes();
+ EnvFactory.getEnv().shutdownAllConfigNodes();
// Close while the servers are down so the old clients cannot remove
persisted subscriptions.
firstConsumer.close();
firstConsumer = null;
@@ -117,7 +115,7 @@ public class IoTDBConsensusSubscriptionRecoveryTableIT
secondConsumer.subscribe(ids.getTopic());
// Do not seek, recreate the topic, or insert new rows to trigger
subscription setup.
- // Track unique rows as a receiver would, allowing redelivery around the
forced shutdown.
+ // Track unique rows as a receiver would, allowing redelivery around the
restart.
expectedRows.addAll(pendingRows);
assertConsumedRows(expectedRows, consumedRows, firstConsumer,
secondConsumer);
diff --git
a/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template
b/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template
index 06f2a43b698..d952bce23ca 100644
---
a/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template
+++
b/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template
@@ -2107,19 +2107,6 @@ pipe_lib_dir=ext/pipe
# Datatype: int
pipe_subtask_executor_max_thread_num=0
-# The maximum number of TsFile parsers that can run concurrently across all
Pipes on this DataNode.
-# When <= 0, use max(1, CPU core number / 2).
-# effectiveMode: hot_reload
-# Datatype: int
-pipe_tsfile_parser_in_flight_max_num=0
-
-# The maximum number of TsFile parsers that can run concurrently for one
DataRegion of one Pipe.
-# Different DataRegions of the same Pipe have independent limits.
-# When <= 0, use 1.
-# effectiveMode: hot_reload
-# Datatype: int
-pipe_tsfile_parser_in_flight_max_num_per_pipe_region=1
-
# The connection timeout (in milliseconds) for the thrift client.
# effectiveMode: restart
# Datatype: int
