diff --git a/src/risedevtool/config/src/main.rs b/src/risedevtool/config/src/main.rs index ac36d475b83c3..79df34bd815dc 100644 --- a/src/risedevtool/config/src/main.rs +++ b/src/risedevtool/config/src/main.rs @@ -396,12 +396,6 @@ fn main() -> Result<()> { )?; if chosen.contains(&component) { writeln!(file, "{}=true", component.env())?; - if component == Components::BuildConnectorNode { - writeln!( - file, - "CONNECTOR_LIBS_PATH=.risingwave/bin/connector-node/libs/" - )?; - } } else { writeln!(file, "# {}=true", component.env())?; } diff --git a/src/risedevtool/src/task/compute_node_service.rs b/src/risedevtool/src/task/compute_node_service.rs index 5bb9c23cbf21f..ced6bec115f6a 100644 --- a/src/risedevtool/src/task/compute_node_service.rs +++ b/src/risedevtool/src/task/compute_node_service.rs @@ -102,6 +102,14 @@ impl Task for ComputeNodeService { cmd.env("MALLOC_CONF", conf); // unprefixed for linux } + if crate::util::is_env_set("ENABLE_BUILD_RW_CONNECTOR") { + let prefix_bin = env::var("PREFIX_BIN")?; + cmd.env( + "CONNECTOR_LIBS_PATH", + Path::new(&prefix_bin).join("connector-node/libs/"), + ); + } + cmd.arg("--config-path") .arg(Path::new(&prefix_config).join("risingwave.toml")); Self::apply_command_args(&mut cmd, &self.config)?; diff --git a/src/risedevtool/src/task/meta_node_service.rs b/src/risedevtool/src/task/meta_node_service.rs index 1b53af8f9b544..2494a9eceaf16 100644 --- a/src/risedevtool/src/task/meta_node_service.rs +++ b/src/risedevtool/src/task/meta_node_service.rs @@ -186,6 +186,14 @@ impl Task for MetaNodeService { cmd.env("MALLOC_CONF", conf); // unprefixed for linux } + if crate::util::is_env_set("ENABLE_BUILD_RW_CONNECTOR") { + let prefix_bin = env::var("PREFIX_BIN")?; + cmd.env( + "CONNECTOR_LIBS_PATH", + Path::new(&prefix_bin).join("connector-node/libs/"), + ); + } + Self::apply_command_args(&mut cmd, &self.config, HummockInMemoryStrategy::Isolated)?; let prefix_config = env::var("PREFIX_CONFIG")?;