diff --git a/dubbo-rpc-default/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/filter/TraceFilter.java b/dubbo-rpc-default/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/filter/TraceFilter.java index c0a9748026..66f47be60c 100644 --- a/dubbo-rpc-default/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/filter/TraceFilter.java +++ b/dubbo-rpc-default/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/filter/TraceFilter.java @@ -108,6 +108,9 @@ public class TraceFilter implements Filter { + "\r\nelapsed: "+(end - start) +" ms." + "\r\n\r\n" + prompt + "> "); } + if(count >= max - 1) { + channels.remove(channel); + } } catch (Throwable e) { channels.remove(channel); logger.warn(e.getMessage(), e);