From 57955667df0c73c56e578d2182288e33387d3a45 Mon Sep 17 00:00:00 2001 From: David Stephan Date: Wed, 12 Oct 2022 08:50:17 +0200 Subject: [PATCH] SED-1456 wrong list of attributes used for ingestion --- .../plugins/timeseries/TimeSeriesBucketingHandler.java | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/step-controller-plugins/step-controller-plugins-timeseries/src/main/java/step/plugins/timeseries/TimeSeriesBucketingHandler.java b/step-controller-plugins/step-controller-plugins-timeseries/src/main/java/step/plugins/timeseries/TimeSeriesBucketingHandler.java index 9f3d26268..fbc30fdcc 100644 --- a/step-controller-plugins/step-controller-plugins-timeseries/src/main/java/step/plugins/timeseries/TimeSeriesBucketingHandler.java +++ b/step-controller-plugins/step-controller-plugins-timeseries/src/main/java/step/plugins/timeseries/TimeSeriesBucketingHandler.java @@ -46,9 +46,7 @@ public void processMeasurement(Measurement measurement) { long value = measurement.getValue(); BucketAttributes bucketAttributes = measurementToBucketAttributes(measurement); - removeKeys(bucketAttributes,"rnId", "origin", "planId", "agentUrl", "id", "begin", "value"); bucketAttributes.put(METRIC_TYPE_KEY, METRIC_TYPE_RESPONSE_TIME); - // custom fields include all the attributes like execId and planId this.ingestionPipeline.ingestPoint(bucketAttributes, begin, value); } @@ -62,19 +60,11 @@ private BucketAttributes measurementToBucketAttributes(Measurement measurement) return new BucketAttributes(bucketAttributesMap); } - private void removeKeys(Map map, String... attributes) { - for (String attribute : attributes) { - map.remove(attribute); - } - } - @Override public void processGauges(List measurements) { measurements.forEach(measurement -> { if (measurement != null && measurement.getType().equals(THREAD_GROUP_MEASUREMENT_TYPE)) { BucketAttributes bucketAttributes = measurementToBucketAttributes(measurement); - bucketAttributes.remove("taskId"); - bucketAttributes.remove("type"); bucketAttributes.put(METRIC_TYPE_KEY, METRIC_TYPE_SAMPLER); this.ingestionPipeline.ingestPoint(bucketAttributes, measurement.getBegin(), measurement.getValue()); }