kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Remove the duplicated tags to reduce the storage payload. (#7469)

This commit is contained in:
CharliePu 2021-08-17 18:01:56 +08:00 committed by GitHub
parent 77bf5de7f6
commit 39d23c1678
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.md
View File

@ -39,6 +39,7 @@ Release Notes.
* [Break Change] Fix typo for a column `page_path_id`(was `pate_path_id`) of storage entity `browser_error_log`.
* Add component id for Python falcon plugin.
* Add `rpcStatusCode` for `rpc.status_code` tag. The `responseCode` field is marked as deprecated and replaced by `httpResponseStatusCode` field.
* Remove the duplicated tags to reduce the storage payload.
#### UI

8
oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/listener/SegmentAnalysisListener.java
View File

@ -19,7 +19,6 @@
package org.apache.skywalking.oap.server.analyzer.provider.trace.parser.listener;
import java.util.Arrays;
import java.util.HashSet;
import java.util.List;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@ -153,17 +152,14 @@ public class SegmentAnalysisListener implements FirstAnalysisListener, EntryAnal
}
private void appendSearchableTags(SpanObject span) {
HashSet<Tag> segmentTags = new HashSet<>();
span.getTagsList().forEach(tag -> {
if (searchableTagKeys.contains(tag.getKey())) {
final Tag spanTag = new Tag(tag.getKey(), tag.getValue());
if (!segmentTags.contains(spanTag)) {
segmentTags.add(spanTag);
if (!segment.getTags().contains(spanTag)) {
segment.getTags().add(spanTag);
}
}
});
segment.getTags().addAll(segmentTags);
}
@Override