diff --git a/cat-consumer/src/main/java/com/dianping/cat/consumer/state/StateAnalyzer.java b/cat-consumer/src/main/java/com/dianping/cat/consumer/state/StateAnalyzer.java index 6ab2c549317026ce1f05163534a25e7f30d01f14..666331179985526d0051002f183bd6113a32dee8 100644 --- a/cat-consumer/src/main/java/com/dianping/cat/consumer/state/StateAnalyzer.java +++ b/cat-consumer/src/main/java/com/dianping/cat/consumer/state/StateAnalyzer.java @@ -86,8 +86,8 @@ public class StateAnalyzer extends AbstractMessageAnalyzer implemen ProcessDomain processDomain = machine.findOrCreateProcessDomain(domain); Detail detail = processDomain.findOrCreateDetail(start); - processDomain.setSize(value + processDomain.getTotalLoss()); - detail.setSize(value + detail.getTotalLoss()); + processDomain.setSize(value + processDomain.getSize()); + detail.setSize(value + detail.getSize()); } long messageTotal = state.getMessageTotal();