Skip to content

Add ImportWAL tool with WAL replay controls - #18516

Open
jt2594838 wants to merge 4 commits into
masterfrom
support_wal_in_import_data
Open

Add ImportWAL tool with WAL replay controls#18516
jt2594838 wants to merge 4 commits into
masterfrom
support_wal_in_import_data

add detailed prompt

fa7f2dd
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Aug 24, 2026 in 7m 57s

Quality Gate failed

Failed conditions
E Reliability Rating on New Code (required ≥ A)

See analysis details on SonarQube Cloud

Catch issues before they fail your Quality Gate with our IDE extension SonarQube for IDE

Annotations

Check warning on line 1331 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Abbreviation in name 'WALReplayException' must contain no more than '2' consecutive capital letters. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4fgf&open=AaAzdUktDJpul7RU4fgf&pullRequest=18516

Check warning on line 667 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Extract this nested try block into a separate method. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUZBDJpul7RU4ffy&open=AaAzdUZBDJpul7RU4ffy&pullRequest=18516

Check warning on line 284 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/partition/PartitionCache.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 101). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUESDJpul7RU4ffN&open=AaAzdUESDJpul7RU4ffN&pullRequest=18516

Check warning on line 105 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this use of System.err by a logger. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4ff-&open=AaAzdUktDJpul7RU4ff-&pullRequest=18516

Check warning on line 588 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Extract this nested try block into a separate method. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4ff4&open=AaAzdUktDJpul7RU4ff4&pullRequest=18516

Check warning on line 354 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Abbreviation in name 'createWALReplayWorker' must contain no more than '2' consecutive capital letters. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4fgK&open=AaAzdUktDJpul7RU4fgK&pullRequest=18516

Check warning on line 834 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 138). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4fgb&open=AaAzdUktDJpul7RU4fgb&pullRequest=18516

Check warning on line 377 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/IoTDBOpcUaClient.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor the code in order to not assign to this loop counter from within the loop body. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUL4DJpul7RU4ffX&open=AaAzdUL4DJpul7RU4ffX&pullRequest=18516

Check warning on line 417 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this usage of 'Stream.collect(Collectors.toList())' with 'Stream.toList()' and ensure that the list is unmodified. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4ff_&open=AaAzdUktDJpul7RU4ff_&pullRequest=18516

Check warning on line 725 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Abbreviation in name 'WALReplayer' must contain no more than '2' consecutive capital letters. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4fga&open=AaAzdUktDJpul7RU4fga&pullRequest=18516

Check warning on line 127 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/IPartitionFetcher.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

All overloaded methods should be placed next to each other. Placing non-overloaded methods in between overloaded methods with the same type is a violation. Previous overloaded method located at line '45'. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUCSDJpul7RU4ffL&open=AaAzdUCSDJpul7RU4ffL&pullRequest=18516

Check failure on line 111 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionBroker.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 16 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUcUDJpul7RU4ffz&open=AaAzdUcUDJpul7RU4ffz&pullRequest=18516

Check warning on line 1220 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Merge the previous cases into this one using comma-separated label. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUngDJpul7RU4fgg&open=AaAzdUngDJpul7RU4fgg&pullRequest=18516

Check failure on line 186 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionSetupHandler.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Define a constant instead of duplicating this literal "root." 3 times. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUfeDJpul7RU4ff2&open=AaAzdUfeDJpul7RU4ff2&pullRequest=18516

Check warning on line 538 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Either re-interrupt this method or rethrow the "InterruptedException" that can be caught here. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4fgB&open=AaAzdUktDJpul7RU4fgB&pullRequest=18516

Check warning on line 150 in iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a thread-safe type; adding "volatile" is not enough to make this field thread-safe. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUvqDJpul7RU4fgi&open=AaAzdUvqDJpul7RU4fgi&pullRequest=18516

Check warning on line 237 in iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a thread-safe type; adding "volatile" is not enough to make this field thread-safe. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUxYDJpul7RU4fgk&open=AaAzdUxYDJpul7RU4fgk&pullRequest=18516

Check warning on line 278 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 107). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUsrDJpul7RU4fgh&open=AaAzdUsrDJpul7RU4fgh&pullRequest=18516

Check warning on line 114 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use the "AtomicReference" API for synchronization instead of a "synchronized" block. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdTyiDJpul7RU4fe_&open=AaAzdTyiDJpul7RU4fe_&pullRequest=18516

Check warning on line 179 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/client/IoTDBOpcUaClient.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove this expression which always evaluates to "false" 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUL4DJpul7RU4ffU&open=AaAzdUL4DJpul7RU4ffU&pullRequest=18516

Check warning on line 866 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove these unused method parameters "req", "loadStatus". 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdTtnDJpul7RU4fe9&open=AaAzdTtnDJpul7RU4fe9&pullRequest=18516

Check failure on line 214 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/util/LoadUtil.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 23 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdT4NDJpul7RU4ffJ&open=AaAzdT4NDJpul7RU4ffJ&pullRequest=18516

Check warning on line 836 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 104). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4fgc&open=AaAzdUktDJpul7RU4fgc&pullRequest=18516

Check failure on line 133 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Define a constant instead of duplicating this literal "thread_num" 3 times. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUktDJpul7RU4ff8&open=AaAzdUktDJpul7RU4ff8&pullRequest=18516

Check warning on line 311 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/request/PipeTransferTsFileSealWithModReq.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Method has 8 parameters, which is greater than 7 authorized. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaAzdUSaDJpul7RU4ffg&open=AaAzdUSaDJpul7RU4ffg&pullRequest=18516
View more details on SonarQubeCloud