diff --git a/influxdb_iox/src/influxdb_ioxd/server_type/database/rpc/storage/service.rs b/influxdb_iox/src/influxdb_ioxd/server_type/database/rpc/storage/service.rs index 7eee0fbcbd..2e52a6a6d0 100644 --- a/influxdb_iox/src/influxdb_ioxd/server_type/database/rpc/storage/service.rs +++ b/influxdb_iox/src/influxdb_ioxd/server_type/database/rpc/storage/service.rs @@ -18,7 +18,7 @@ use generated_types::{ ReadWindowAggregateRequest, StringValuesResponse, TagKeyMetaNames, TagKeysRequest, TagValuesRequest, TimestampRange, }; -use observability_deps::tracing::{error, info}; +use observability_deps::tracing::{error, info, trace}; use predicate::predicate::PredicateBuilder; use query::exec::{ fieldlist::FieldList, seriesset::converter::Error as SeriesSetError, ExecutionContextProvider, @@ -735,6 +735,7 @@ where .map(|name| name.bytes().collect()) .collect(); + trace!(measurement_names=?values.iter().map(|k| String::from_utf8_lossy(k)).collect::>(), "Measurement names response"); Ok(StringValuesResponse { values }) } @@ -786,10 +787,8 @@ where // Map the resulting collection of Strings into a Vec>for return let values = tag_keys_to_byte_vecs(tag_keys); - // Debugging help: uncomment this out to see what is coming back - // info!("Returning tag keys"); - // values.iter().for_each(|k| info!(" {}", String::from_utf8_lossy(k))); + trace!(tag_keys=?values.iter().map(|k| String::from_utf8_lossy(k)).collect::>(), "Tag keys response"); Ok(StringValuesResponse { values }) } @@ -842,10 +841,7 @@ where .map(|name| name.bytes().collect()) .collect(); - // Debugging help: uncomment to see raw values coming back - //info!("Returning tag values"); - //values.iter().for_each(|k| info!(" {}", String::from_utf8_lossy(k))); - + trace!(tag_values=?values.iter().map(|k| String::from_utf8_lossy(k)).collect::>(), "Tag values response"); Ok(StringValuesResponse { values }) } @@ -1004,6 +1000,7 @@ where .map_err(|e| Box::new(e) as _) .context(ListingFields { db_name })?; + trace!(field_names=?field_list, "Field names response"); Ok(field_list) }