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

fix: Actually use the bind addrs when running the compactor once

pull/24376/head
Carol (Nichols || Goulding) 2023-03-20 11:53:03 -04:00
parent 528d83e989
commit 01a609af45
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
test_helpers_end_to_end/src/mini_cluster.rs
View File

@ -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);