diff --git a/src/servers/src/otlp.rs b/src/servers/src/otlp.rs index 8586d79f779c..3acfaf0a881b 100644 --- a/src/servers/src/otlp.rs +++ b/src/servers/src/otlp.rs @@ -232,7 +232,7 @@ fn encode_sum( Ok(()) } -const HISTOGRAM_LE_COLUMN: &str = "greptime_le"; +const HISTOGRAM_LE_COLUMN: &str = "le"; /// Encode histogram data. This function returns 3 insert requests for 3 tables. /// diff --git a/tests-integration/src/otlp.rs b/tests-integration/src/otlp.rs index 71a85d68606a..942fad14a551 100644 --- a/tests-integration/src/otlp.rs +++ b/tests-integration/src/otlp.rs @@ -92,7 +92,7 @@ mod test { let mut output = instance .do_query( - "SELECT greptime_le, greptime_value FROM my_test_histo_bucket order by greptime_le", + "SELECT le, greptime_value FROM my_test_histo_bucket order by le", ctx.clone(), ) .await; @@ -101,17 +101,16 @@ mod test { unreachable!() }; let recordbatches = RecordBatches::try_collect(stream).await.unwrap(); - dbg!(&recordbatches); assert_eq!( recordbatches.pretty_print().unwrap(), "\ -+-------------+----------------+ -| greptime_le | greptime_value | -+-------------+----------------+ -| 1 | 1.0 | -| 5 | 3.0 | -| inf | 4.0 | -+-------------+----------------+", ++-----+----------------+ +| le | greptime_value | ++-----+----------------+ +| 1 | 1.0 | +| 5 | 3.0 | +| inf | 4.0 | ++-----+----------------+", ); let mut output = instance