diff --git a/test_helpers_end_to_end/src/mini_cluster.rs b/test_helpers_end_to_end/src/mini_cluster.rs index b021e04437..cc0170435c 100644 --- a/test_helpers_end_to_end/src/mini_cluster.rs +++ b/test_helpers_end_to_end/src/mini_cluster.rs @@ -1,6 +1,6 @@ use crate::{ - dump_log_to_stdout, log_command, rand_id, write_to_ingester, write_to_router, ServerFixture, - TestConfig, TestServer, + dump_log_to_stdout, log_command, rand_id, server_type::AddAddrEnv, write_to_ingester, + write_to_router, ServerFixture, TestConfig, TestServer, }; use arrow::{datatypes::SchemaRef, record_batch::RecordBatch}; use arrow_flight::{ @@ -478,7 +478,6 @@ impl MiniCluster { .arg("--compaction-process-once") .arg("--compaction-process-all-partitions") .env("LOG_FILTER", log_filter) - .env("INFLUXDB_IOX_GRPC_BIND_ADDR", "8999") .env( "INFLUXDB_IOX_CATALOG_DSN", self.compactor_config() @@ -491,6 +490,10 @@ impl MiniCluster { self.compactor_config().catalog_schema_name(), ) .envs(self.compactor_config().env()) + .add_addr_env( + self.compactor_config().server_type(), + self.compactor_config().addrs(), + ) // redirect output to log file .stdout(stdout_log_file) .stderr(stderr_log_file);