diff --git a/apm-collector/apm-collector-analysis/analysis-metric/metric-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/metric/provider/AnalysisMetricModuleProvider.java b/apm-collector/apm-collector-analysis/analysis-metric/metric-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/metric/provider/AnalysisMetricModuleProvider.java index 4258a28738..35db2d9e36 100644 --- a/apm-collector/apm-collector-analysis/analysis-metric/metric-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/metric/provider/AnalysisMetricModuleProvider.java +++ b/apm-collector/apm-collector-analysis/analysis-metric/metric-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/metric/provider/AnalysisMetricModuleProvider.java @@ -100,14 +100,14 @@ public class AnalysisMetricModuleProvider extends ModuleProvider { private void segmentParserListenerRegister() { ISegmentParserListenerRegister segmentParserListenerRegister = getManager().find(AnalysisSegmentParserModule.NAME).getService(ISegmentParserListenerRegister.class); - segmentParserListenerRegister.register(new ServiceReferenceMetricSpanListener.Factory()); //11000TPS - segmentParserListenerRegister.register(new ApplicationComponentSpanListener.Factory()); //17000TPS - segmentParserListenerRegister.register(new ApplicationMappingSpanListener.Factory()); //22000TPS - segmentParserListenerRegister.register(new InstanceMappingSpanListener.Factory()); //22000TPS - segmentParserListenerRegister.register(new GlobalTraceSpanListener.Factory()); //15000TPS - segmentParserListenerRegister.register(new SegmentDurationSpanListener.Factory()); //13000TPS - segmentParserListenerRegister.register(new ResponseTimeDistributionSpanListener.Factory()); //25000TPS - segmentParserListenerRegister.register(new ServiceNameSpanListener.Factory()); //20000TPS + segmentParserListenerRegister.register(new ServiceReferenceMetricSpanListener.Factory()); + segmentParserListenerRegister.register(new ApplicationComponentSpanListener.Factory()); + segmentParserListenerRegister.register(new ApplicationMappingSpanListener.Factory()); + segmentParserListenerRegister.register(new InstanceMappingSpanListener.Factory()); + segmentParserListenerRegister.register(new GlobalTraceSpanListener.Factory()); + segmentParserListenerRegister.register(new SegmentDurationSpanListener.Factory()); + segmentParserListenerRegister.register(new ResponseTimeDistributionSpanListener.Factory()); + segmentParserListenerRegister.register(new ServiceNameSpanListener.Factory()); } private void graphCreate(WorkerCreateListener workerCreateListener) { diff --git a/apm-collector/apm-collector-analysis/analysis-segment-parser/segment-parser-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/segment/parser/provider/parser/SegmentParse.java b/apm-collector/apm-collector-analysis/analysis-segment-parser/segment-parser-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/segment/parser/provider/parser/SegmentParse.java index 335cbab8f7..2c6ef58125 100644 --- a/apm-collector/apm-collector-analysis/analysis-segment-parser/segment-parser-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/segment/parser/provider/parser/SegmentParse.java +++ b/apm-collector/apm-collector-analysis/analysis-segment-parser/segment-parser-provider/src/main/java/org/apache/skywalking/apm/collector/analysis/segment/parser/provider/parser/SegmentParse.java @@ -82,10 +82,10 @@ public class SegmentParse { buildSegment(segmentCoreInfo.getSegmentId(), segmentDecorator.toByteArray()); return true; } - } catch (InvalidProtocolBufferException e) { + } catch (Throwable e) { logger.error(e.getMessage(), e); + return true; } - return false; } @GraphComputingMetric(name = "/segment/parse/parseBinarySegment")