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

fix: main (#25231)

pull/25233/head
Trevor Hilton 2024-08-08 08:56:09 -07:00 committed by GitHub
parent 05ab730ae6
commit 2082135077
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
influxdb3_server/src/query_executor.rs
View File

@ -581,10 +581,8 @@ mod tests {
use data_types::NamespaceName;
use datafusion::{assert_batches_sorted_eq, error::DataFusionError};
use futures::TryStreamExt;
use influxdb3_wal::WalConfig;
use influxdb3_write::{
persister::PersisterImpl, write_buffer::WriteBufferImpl, Bufferer, Level0Duration,
};
use influxdb3_wal::{Level0Duration, WalConfig};
use influxdb3_write::{persister::PersisterImpl, write_buffer::WriteBufferImpl, Bufferer};
use iox_query::exec::{DedicatedExecutor, Executor, ExecutorConfig};
use iox_time::{MockProvider, Time};
use metric::Registry;
@ -626,15 +624,13 @@ mod tests {
let persister = Arc::new(PersisterImpl::new(Arc::clone(&object_store), "test_host"));
let time_provider = Arc::new(MockProvider::new(Time::from_timestamp_nanos(0)));
let executor = make_exec(object_store);
let level_0_duration = Level0Duration::new_5m();
let write_buffer = Arc::new(
WriteBufferImpl::new(
Arc::clone(&persister),
Arc::clone(&time_provider),
level_0_duration,
Arc::clone(&executor),
WalConfig {
level_0_duration: Duration::from_secs(60),
level_0_duration: Level0Duration::new_1m(),
max_write_buffer_size: 100,
flush_interval: Duration::from_millis(10),
snapshot_size: 1,