提交 b35eaace 编写于 作者: 彭勇升 pengys 提交者: wu-sheng

[Collector] Tolerate and ignore unsupport segments (#1385)

* #1207

Return true when segment parse throw exception to avoid parse the segment over and over again which read from buffer file.

* no message
上级 5e03ec88
......@@ -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) {
......
......@@ -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")
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册