[incubator-skywalking] branch new-consumer-pool updated: Set SegmentStandardizationWorker data carrier name.

[wu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch new-consumer-pool
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git


The following commit(s) were added to refs/heads/new-consumer-pool by this push:
     new b05553e  Set SegmentStandardizationWorker data carrier name.
b05553e is described below

commit b05553e4e819507f37ccfc21b3b04882a7beb0d6
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Fri Feb 15 21:51:09 2019 +0800

    Set SegmentStandardizationWorker data carrier name.
---
 .../provider/parser/standardization/SegmentStandardizationWorker.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/standardization/SegmentStandardizationWorker.java b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/standardization/SegmentStandardizationWorker.java
index 78deb6a..46a9117 100644
--- a/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/standardization/SegmentStandardizationWorker.java
+++ b/oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/standardization/SegmentStandardizationWorker.java
@@ -56,7 +56,7 @@ public class SegmentStandardizationWorker extends AbstractWorker<SegmentStandard
         BufferStream<UpstreamSegment> stream = builder.build();
         stream.initialize();
 
-        dataCarrier = new DataCarrier<>(1, 1024);
+        dataCarrier = new DataCarrier<>("SegmentStandardizationWorker", 1, 1024);
         dataCarrier.consume(new Consumer(stream), 1, 200);
 
         MetricCreator metricCreator = moduleManager.find(TelemetryModule.NAME).provider().getService(MetricCreator.class);