diff --git a/pkg/telemetrymetadata/stmt_parse.go b/pkg/telemetrymetadata/stmt_parse.go index 726d45a86268..deff14f82a57 100644 --- a/pkg/telemetrymetadata/stmt_parse.go +++ b/pkg/telemetrymetadata/stmt_parse.go @@ -63,11 +63,11 @@ func (v *TelemetryFieldVisitor) VisitColumnDef(expr *parser.ColumnDef) error { case "bool": fieldDataType = telemetrytypes.FieldDataTypeBool case "int", "int64": - fieldDataType = telemetrytypes.FieldDataTypeFloat64 + fieldDataType = telemetrytypes.FieldDataTypeNumber case "float", "float64": - fieldDataType = telemetrytypes.FieldDataTypeFloat64 + fieldDataType = telemetrytypes.FieldDataTypeNumber case "number": - fieldDataType = telemetrytypes.FieldDataTypeFloat64 + fieldDataType = telemetrytypes.FieldDataTypeNumber default: return nil // Unknown data type } diff --git a/pkg/telemetrymetadata/stmt_parse_test.go b/pkg/telemetrymetadata/stmt_parse_test.go index 73f386e691f0..9ce61647a088 100644 --- a/pkg/telemetrymetadata/stmt_parse_test.go +++ b/pkg/telemetrymetadata/stmt_parse_test.go @@ -121,7 +121,7 @@ func TestExtractFieldKeysFromTblStatement(t *testing.T) { { Name: "input_size", FieldContext: telemetrytypes.FieldContextAttribute, - FieldDataType: telemetrytypes.FieldDataTypeFloat64, + FieldDataType: telemetrytypes.FieldDataTypeNumber, Materialized: true, }, {