fix remove blacklist labels
@@ -145,10 +145,12 @@ func (sink *influxdbSink) ExportData(dataBatch *core.DataBatch) {
}
for key, value := range metricSet.Labels {
+ if _, exists := influxdbBlacklistLabels[key]; !exists {
if value != "" {
point.Tags[key] = value
}
}
+ }
for key, value := range labeledMetric.Labels {
if _, exists := influxdbBlacklistLabels[key]; !exists {
if value != "" {
