Skip to content

Commit de6d38d

Browse files
jt2594838jt2594838
committed
spotless
1 parent 624d620 commit de6d38d

1 file changed

Lines changed: 70 additions & 67 deletions

File tree

‎integration-test/src/main/java/org/apache/iotdb/it/env/cluster/node/AbstractNodeWrapper.java‎

Lines changed: 70 additions & 67 deletions
Original file line numberDiff line numberDiff line change
@@ -337,63 +337,66 @@ private void reloadClusterConfigurations() {
337337
switch (getValueOfIndex(valueStr, clusterIndex)) {
338338
case LIGHT_WEIGHT_STANDALONE_MODE:
339339
clusterConfigProperties.setProperty(
340-
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
341-
fromConsensusAbbrToFullName(
342-
System.getProperty(LIGHT_WEIGHT_STANDALONE_MODE_CONFIG_NODE_CONSENSUS, "Simple")));
340+
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
341+
fromConsensusAbbrToFullName(
342+
System.getProperty(
343+
LIGHT_WEIGHT_STANDALONE_MODE_CONFIG_NODE_CONSENSUS, "Simple")));
343344
clusterConfigProperties.setProperty(
344-
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
345-
fromConsensusAbbrToFullName(
346-
System.getProperty(LIGHT_WEIGHT_STANDALONE_MODE_SCHEMA_REGION_CONSENSUS, "Simple")));
345+
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
346+
fromConsensusAbbrToFullName(
347+
System.getProperty(
348+
LIGHT_WEIGHT_STANDALONE_MODE_SCHEMA_REGION_CONSENSUS, "Simple")));
347349
clusterConfigProperties.setProperty(
348-
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
349-
fromConsensusAbbrToFullName(
350-
System.getProperty(LIGHT_WEIGHT_STANDALONE_MODE_DATA_REGION_CONSENSUS, "Simple")));
350+
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
351+
fromConsensusAbbrToFullName(
352+
System.getProperty(
353+
LIGHT_WEIGHT_STANDALONE_MODE_DATA_REGION_CONSENSUS, "Simple")));
351354
clusterConfigProperties.setProperty(
352-
SCHEMA_REPLICATION_FACTOR,
353-
System.getProperty(LIGHT_WEIGHT_STANDALONE_MODE_SCHEMA_REGION_REPLICA_NUM, "1"));
355+
SCHEMA_REPLICATION_FACTOR,
356+
System.getProperty(LIGHT_WEIGHT_STANDALONE_MODE_SCHEMA_REGION_REPLICA_NUM, "1"));
354357
clusterConfigProperties.setProperty(
355-
DATA_REPLICATION_FACTOR,
356-
System.getProperty(LIGHT_WEIGHT_STANDALONE_MODE_DATA_REGION_REPLICA_NUM, "1"));
358+
DATA_REPLICATION_FACTOR,
359+
System.getProperty(LIGHT_WEIGHT_STANDALONE_MODE_DATA_REGION_REPLICA_NUM, "1"));
357360
break;
358361
case SCALABLE_SINGLE_NODE_MODE:
359362
clusterConfigProperties.setProperty(
360-
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
361-
fromConsensusAbbrToFullName(
362-
System.getProperty(SCALABLE_SINGLE_NODE_MODE_CONFIG_NODE_CONSENSUS, "Ratis")));
363+
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
364+
fromConsensusAbbrToFullName(
365+
System.getProperty(SCALABLE_SINGLE_NODE_MODE_CONFIG_NODE_CONSENSUS, "Ratis")));
363366
clusterConfigProperties.setProperty(
364-
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
365-
fromConsensusAbbrToFullName(
366-
System.getProperty(SCALABLE_SINGLE_NODE_MODE_SCHEMA_REGION_CONSENSUS, "Ratis")));
367+
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
368+
fromConsensusAbbrToFullName(
369+
System.getProperty(SCALABLE_SINGLE_NODE_MODE_SCHEMA_REGION_CONSENSUS, "Ratis")));
367370
clusterConfigProperties.setProperty(
368-
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
369-
fromConsensusAbbrToFullName(
370-
System.getProperty(SCALABLE_SINGLE_NODE_MODE_DATA_REGION_CONSENSUS, "IoT")));
371+
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
372+
fromConsensusAbbrToFullName(
373+
System.getProperty(SCALABLE_SINGLE_NODE_MODE_DATA_REGION_CONSENSUS, "IoT")));
371374
clusterConfigProperties.setProperty(
372-
SCHEMA_REPLICATION_FACTOR,
373-
System.getProperty(SCALABLE_SINGLE_NODE_MODE_SCHEMA_REGION_REPLICA_NUM, "1"));
375+
SCHEMA_REPLICATION_FACTOR,
376+
System.getProperty(SCALABLE_SINGLE_NODE_MODE_SCHEMA_REGION_REPLICA_NUM, "1"));
374377
clusterConfigProperties.setProperty(
375-
DATA_REPLICATION_FACTOR,
376-
System.getProperty(SCALABLE_SINGLE_NODE_MODE_DATA_REGION_REPLICA_NUM, "1"));
378+
DATA_REPLICATION_FACTOR,
379+
System.getProperty(SCALABLE_SINGLE_NODE_MODE_DATA_REGION_REPLICA_NUM, "1"));
377380
break;
378381
case HIGH_PERFORMANCE_MODE:
379382
clusterConfigProperties.setProperty(
380-
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
381-
fromConsensusAbbrToFullName(
382-
System.getProperty(HIGH_PERFORMANCE_MODE_CONFIG_NODE_CONSENSUS, "Ratis")));
383+
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
384+
fromConsensusAbbrToFullName(
385+
System.getProperty(HIGH_PERFORMANCE_MODE_CONFIG_NODE_CONSENSUS, "Ratis")));
383386
clusterConfigProperties.setProperty(
384-
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
385-
fromConsensusAbbrToFullName(
386-
System.getProperty(HIGH_PERFORMANCE_MODE_SCHEMA_REGION_CONSENSUS, "Ratis")));
387+
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
388+
fromConsensusAbbrToFullName(
389+
System.getProperty(HIGH_PERFORMANCE_MODE_SCHEMA_REGION_CONSENSUS, "Ratis")));
387390
clusterConfigProperties.setProperty(
388-
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
389-
fromConsensusAbbrToFullName(
390-
System.getProperty(HIGH_PERFORMANCE_MODE_DATA_REGION_CONSENSUS, "IoT")));
391+
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
392+
fromConsensusAbbrToFullName(
393+
System.getProperty(HIGH_PERFORMANCE_MODE_DATA_REGION_CONSENSUS, "IoT")));
391394
clusterConfigProperties.setProperty(
392-
SCHEMA_REPLICATION_FACTOR,
393-
System.getProperty(HIGH_PERFORMANCE_MODE_SCHEMA_REGION_REPLICA_NUM, "3"));
395+
SCHEMA_REPLICATION_FACTOR,
396+
System.getProperty(HIGH_PERFORMANCE_MODE_SCHEMA_REGION_REPLICA_NUM, "3"));
394397
clusterConfigProperties.setProperty(
395-
DATA_REPLICATION_FACTOR,
396-
System.getProperty(HIGH_PERFORMANCE_MODE_DATA_REGION_REPLICA_NUM, "2"));
398+
DATA_REPLICATION_FACTOR,
399+
System.getProperty(HIGH_PERFORMANCE_MODE_DATA_REGION_REPLICA_NUM, "2"));
397400
break;
398401
case STRONG_CONSISTENCY_CLUSTER_MODE:
399402
clusterConfigProperties.setProperty(
@@ -417,49 +420,49 @@ private void reloadClusterConfigurations() {
417420
break;
418421
case PIPE_CONSENSUS_BATCH_MODE:
419422
clusterConfigProperties.setProperty(
420-
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
421-
fromConsensusAbbrToFullName(
422-
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_CONFIG_NODE_CONSENSUS, "Ratis")));
423+
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
424+
fromConsensusAbbrToFullName(
425+
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_CONFIG_NODE_CONSENSUS, "Ratis")));
423426
clusterConfigProperties.setProperty(
424-
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
425-
fromConsensusAbbrToFullName(
426-
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_SCHEMA_REGION_CONSENSUS, "Ratis")));
427+
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
428+
fromConsensusAbbrToFullName(
429+
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_SCHEMA_REGION_CONSENSUS, "Ratis")));
427430
clusterConfigProperties.setProperty(
428-
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
429-
fromConsensusAbbrToFullName(
430-
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_DATA_REGION_CONSENSUS, "IoTV2")));
431+
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
432+
fromConsensusAbbrToFullName(
433+
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_DATA_REGION_CONSENSUS, "IoTV2")));
431434
clusterConfigProperties.setProperty(
432-
SCHEMA_REPLICATION_FACTOR,
433-
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_SCHEMA_REGION_REPLICA_NUM, "3"));
435+
SCHEMA_REPLICATION_FACTOR,
436+
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_SCHEMA_REGION_REPLICA_NUM, "3"));
434437
clusterConfigProperties.setProperty(
435-
DATA_REPLICATION_FACTOR,
436-
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_DATA_REGION_REPLICA_NUM, "2"));
438+
DATA_REPLICATION_FACTOR,
439+
System.getProperty(PIPE_CONSENSUS_BATCH_MODE_DATA_REGION_REPLICA_NUM, "2"));
437440
// set mode
438441
clusterConfigProperties.setProperty(
439-
IOT_CONSENSUS_V2_MODE, ConsensusFactory.IOT_CONSENSUS_V2_BATCH_MODE);
442+
IOT_CONSENSUS_V2_MODE, ConsensusFactory.IOT_CONSENSUS_V2_BATCH_MODE);
440443
break;
441444
case PIPE_CONSENSUS_STREAM_MODE:
442445
clusterConfigProperties.setProperty(
443-
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
444-
fromConsensusAbbrToFullName(
445-
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_CONFIG_NODE_CONSENSUS, "Ratis")));
446+
CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS,
447+
fromConsensusAbbrToFullName(
448+
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_CONFIG_NODE_CONSENSUS, "Ratis")));
446449
clusterConfigProperties.setProperty(
447-
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
448-
fromConsensusAbbrToFullName(
449-
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_SCHEMA_REGION_CONSENSUS, "Ratis")));
450+
SCHEMA_REGION_CONSENSUS_PROTOCOL_CLASS,
451+
fromConsensusAbbrToFullName(
452+
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_SCHEMA_REGION_CONSENSUS, "Ratis")));
450453
clusterConfigProperties.setProperty(
451-
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
452-
fromConsensusAbbrToFullName(
453-
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_DATA_REGION_CONSENSUS, "IoTV2")));
454+
DATA_REGION_CONSENSUS_PROTOCOL_CLASS,
455+
fromConsensusAbbrToFullName(
456+
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_DATA_REGION_CONSENSUS, "IoTV2")));
454457
clusterConfigProperties.setProperty(
455-
SCHEMA_REPLICATION_FACTOR,
456-
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_SCHEMA_REGION_REPLICA_NUM, "3"));
458+
SCHEMA_REPLICATION_FACTOR,
459+
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_SCHEMA_REGION_REPLICA_NUM, "3"));
457460
clusterConfigProperties.setProperty(
458-
DATA_REPLICATION_FACTOR,
459-
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_DATA_REGION_REPLICA_NUM, "2"));
461+
DATA_REPLICATION_FACTOR,
462+
System.getProperty(PIPE_CONSENSUS_STREAM_MODE_DATA_REGION_REPLICA_NUM, "2"));
460463
// set mode
461464
clusterConfigProperties.setProperty(
462-
IOT_CONSENSUS_V2_MODE, ConsensusFactory.IOT_CONSENSUS_V2_STREAM_MODE);
465+
IOT_CONSENSUS_V2_MODE, ConsensusFactory.IOT_CONSENSUS_V2_STREAM_MODE);
463466
break;
464467
default:
465468
// Print nothing to avoid polluting test outputs

0 commit comments

Comments
 (0)