diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java index 784a54d28..dea1708ee 100644 --- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java +++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java @@ -126,7 +126,6 @@ public class DataSenderFactoryWithBalance { logger.log(Level.ALL, "Sleep failed."); } } - // 找到可以替换的Sender usingDataSender.set(i, newSender); unusedServerAddresses.add(usingDataSender.get(i).getServerIp()); if (usingDataSender.size() >= maxKeepConnectingSenderSize) { @@ -148,7 +147,6 @@ public class DataSenderFactoryWithBalance { toBeSwitchSender = usingDataSender.get(toBeSwitchIndex); if (toBeSwitchSender.getStatus() == DataSender.SenderStatus.READY) { tmpSender = findReadySender(); - // 找到可以替换的Sender if (tmpSender != null) { usingDataSender.set(toBeSwitchIndex, tmpSender); try {