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 31c6d876d0713ff78215459a222c662f84a682d1..b304d67661c8debeda0e4d56ca1bd81c197d3a9b 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 @@ -202,9 +202,7 @@ public class DataSenderFactoryWithBalance { } private static DataSender findReadySender() { - DataSender result = null; - int index = 0; if (unusedServerAddresses.size() > 1){ @@ -234,11 +232,7 @@ public class DataSenderFactoryWithBalance { } public static void unRegister(DataSender socket) { - int index = usingDataSender.indexOf(socket); - if (index != -1) { - usingDataSender.get(index) - .setStatus(DataSender.SenderStatus.FAILED); - } + socket.setStatus(DataSender.SenderStatus.FAILED); } private static String listUsingServers(){