This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch jira6061_cp in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit aef6402ef9d3a83fbb6e64e88a1e2caa512b77b8 Author: OneSizeFitQuorum <[email protected]> AuthorDate: Tue Aug 29 19:38:53 2023 +0800 enhance Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../org/apache/iotdb/consensus/iot/ReplicateTest.java | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) diff --git a/iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/ReplicateTest.java b/iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/ReplicateTest.java index 2c202324b2a..03903319cee 100644 --- a/iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/ReplicateTest.java +++ b/iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/iot/ReplicateTest.java @@ -23,6 +23,7 @@ import org.apache.iotdb.common.rpc.thrift.TConsensusGroupType; import org.apache.iotdb.common.rpc.thrift.TEndPoint; import org.apache.iotdb.commons.consensus.ConsensusGroupId; import org.apache.iotdb.commons.consensus.DataRegionId; +import org.apache.iotdb.commons.exception.StartupException; import org.apache.iotdb.consensus.ConsensusFactory; import org.apache.iotdb.consensus.common.ConsensusGroup; import org.apache.iotdb.consensus.common.Peer; @@ -233,7 +234,13 @@ public class ReplicateTest { CHECK_POINT_GAP, servers.get(2).getImpl(gid).getCurrentSafelyDeletedSearchIndex()); } catch (IOException e) { - logger.info("can not start IoTConsensus because", e); + if (e.getCause() instanceof StartupException) { + // just succeed when can not bind socket + logger.info("Can not start IoTConsensus because", e); + } else { + logger.error("Failed because", e); + Assert.fail("Failed because " + e.getMessage()); + } } } @@ -296,7 +303,13 @@ public class ReplicateTest { Assert.assertEquals(stateMachines.get(0).getData(), stateMachines.get(1).getData()); Assert.assertEquals(stateMachines.get(2).getData(), stateMachines.get(1).getData()); } catch (IOException e) { - logger.info("can not start IoTConsensus because", e); + if (e.getCause() instanceof StartupException) { + // just succeed when can not bind socket + logger.info("Can not start IoTConsensus because", e); + } else { + logger.error("Failed because", e); + Assert.fail("Failed because " + e.getMessage()); + } } }
