Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: cleanup

pull/24376/head
Nga Tran 2021-09-22 16:42:46 -04:00
parent 400ec93498
commit 3a00d9c70a
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
query_tests/src/sql.rs
View File

@ -28,8 +28,6 @@ macro_rules! run_sql_test_case {
let physical_plan = planner.query(&sql, &ctx).expect("built plan successfully"); let physical_plan = planner.query(&sql, &ctx).expect("built plan successfully");
//println!(" --- Physical plan: {:#?}", physical_plan);
let results: Vec<RecordBatch> = ctx.collect(physical_plan).await.expect("Running plan"); let results: Vec<RecordBatch> = ctx.collect(physical_plan).await.expect("Running plan");
assert_batches_sorted_eq!($EXPECTED_LINES, &results); assert_batches_sorted_eq!($EXPECTED_LINES, &results);
} }
@ -752,10 +750,8 @@ async fn sql_predicate_pushdown_correctness_13() {
#[tokio::test] #[tokio::test]
async fn sql_deduplicate_1() { async fn sql_deduplicate_1() {
// This current expected is wrong because deduplicate is not available yet // This current expected is wrong because deduplicate is not available yet
// let sql =
// "select time, state, city, min_temp, max_temp, area from h2o order by time, state, city";
let sql = let sql =
"select time, state, city, min_temp, max_temp, area from h2o order by state, city, time"; "select time, state, city, min_temp, max_temp, area from h2o order by time, state, city";
let expected = vec![ let expected = vec![
"+--------------------------------+-------+---------+----------+----------+------+", "+--------------------------------+-------+---------+----------+----------+------+",
"| time | state | city | min_temp | max_temp | area |", "| time | state | city | min_temp | max_temp | area |",