diff --git a/plugins/outputs/clickhouse/clickhouse.go b/plugins/outputs/clickhouse/clickhouse.go index 95f5be1..5a39706 100644 --- a/plugins/outputs/clickhouse/clickhouse.go +++ b/plugins/outputs/clickhouse/clickhouse.go @@ -160,10 +160,10 @@ func (ch *ClickHouse) toDatatype(value interface{}) string { func (ch *ClickHouse) toNullableDatatype(key string, value interface{}) string { datatype := ch.toDatatype(value) - if key != "host" && key != ch.TimestampColumn && key != "measurement" { - return fmt.Sprintf("Nullable(%s)", datatype) + if key == "host" || key == "measurement" { + return fmt.Sprintf("LowCardinality(%s)", datatype) } - return datatype + return fmt.Sprintf("Nullable(%s)", datatype) } func (ch *ClickHouse) pepareMetrics(metrics []telegraf.Metric, metricsData map[string][]map[string]interface{}, columns map[string]*orderedmap.OrderedMap[string, string]) {