From d051f231dcd6a4b323b451b2a18eb7f224c2e2da Mon Sep 17 00:00:00 2001 From: ascrutae Date: Thu, 7 Apr 2016 20:09:48 +0800 Subject: [PATCH] =?UTF-8?q?Fix:#41=20=E5=A2=9E=E5=8A=A0=E5=BC=82=E5=B8=B8?= =?UTF-8?q?=E5=A4=84=E7=90=86=EF=BC=8CChain=E7=9A=84=E8=8A=82=E7=82=B9?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E6=97=B6=EF=BC=8C=E5=B0=86=E4=BC=9A=E9=87=8D?= =?UTF-8?q?=E5=81=9A=EF=BC=8C=E4=BF=9D=E8=AF=81=E6=9C=8D=E5=8A=A1=E7=AB=AF?= =?UTF-8?q?=E7=9A=84=E6=95=B0=E6=8D=AE=E4=B8=8D=E4=B8=A2=E5=A4=B1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/cloud/skywalking/reciever/storage/Chain.java | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/Chain.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/Chain.java index aa75c37e2..f27ad77b6 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/Chain.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/storage/Chain.java @@ -3,16 +3,15 @@ package com.ai.cloud.skywalking.reciever.storage; import com.ai.cloud.skywalking.protocol.Span; import com.ai.cloud.skywalking.reciever.selfexamination.ServerHealthCollector; import com.ai.cloud.skywalking.reciever.selfexamination.ServerHeathReading; - -import java.util.List; - import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; +import java.util.List; + public class Chain { - private static Logger logger = LogManager + private static Logger logger = LogManager .getLogger(Chain.class); - + private List chains; private int index = 0; @@ -28,9 +27,11 @@ public class Chain { chains.get(index++).doChain(spans, this); break; } catch (Throwable e) { - logger.error("do chain at index[{}] failure.", index, e); + logger.error("do chain at index[{}] failure.", index, e); ServerHealthCollector.getCurrentHeathReading("storage-chain").updateData(ServerHeathReading.ERROR, "Failed to do chain action. spans list hash code:" + spans.hashCode() + ",Cause:" + e.getMessage()); + // 如果Chain出现任何异常，将重做Chain,保证数据不丢失 + index--; } } }