This is an automated email from the ASF dual-hosted git repository. hzh0425 pushed a commit to branch fix/issue-5663 in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 69876463073f5ef92329d5cffdb48698628de51e Author: hzh0425 <[email protected]> AuthorDate: Sun Jan 1 17:00:33 2023 +0800 pass checkstyle --- .../org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHATest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/store/src/test/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHATest.java b/store/src/test/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHATest.java index aa15d3e36..c2c1ec6a4 100644 --- a/store/src/test/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHATest.java +++ b/store/src/test/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHATest.java @@ -459,15 +459,15 @@ public class AutoSwitchHATest { // Step2: check flag SynchronizingSyncStateSet Assert.assertTrue(masterHAService.isSynchronizingSyncStateSet()); Assert.assertEquals(masterHAService.getConfirmOffset(), 1570); - Set<String> syncStateSet = (masterHAService.getSyncStateSet()); + Set<String> syncStateSet = masterHAService.getSyncStateSet(); Assert.assertEquals(syncStateSet.size(), 2); Assert.assertTrue(syncStateSet.contains("127.0.0.1:8001")); // Step3: set new syncStateSet HashSet<String> newSyncStateSet = new HashSet<String>() {{ - add("127.0.0.1:8000"); - add("127.0.0.1:8001"); - }}; + add("127.0.0.1:8000"); + add("127.0.0.1:8001"); + }}; masterHAService.setSyncStateSet(newSyncStateSet); Assert.assertFalse(masterHAService.isSynchronizingSyncStateSet()); }
