From ecfc7d857ce7256da4800018c1984b776d126971 Mon Sep 17 00:00:00 2001 From: Dan Harris <1327726+thinkharderdev@users.noreply.github.com> Date: Tue, 21 Dec 2021 20:24:38 -0500 Subject: [PATCH] =?UTF-8?q?Pass=20local=20address=20host=20so=20we=20do=20?= =?UTF-8?q?not=20get=20mismatch=20between=20IPv4=20and=20IP=E2=80=A6=20(#1?= =?UTF-8?q?466)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * Pass local address host so we do not get mismatch between IPv4 and IPv6 addresses --- ballista/rust/executor/src/standalone.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/ballista/rust/executor/src/standalone.rs b/ballista/rust/executor/src/standalone.rs index 39a899c6c630..04174d4de214 100644 --- a/ballista/rust/executor/src/standalone.rs +++ b/ballista/rust/executor/src/standalone.rs @@ -20,6 +20,7 @@ use std::sync::Arc; use arrow_flight::flight_service_server::FlightServiceServer; use ballista_core::{ error::Result, + serde::protobuf::executor_registration::OptionalHost, serde::protobuf::{scheduler_grpc_client::SchedulerGrpcClient, ExecutorRegistration}, BALLISTA_VERSION, }; @@ -59,7 +60,7 @@ pub async fn new_standalone_executor( ); let executor_meta = ExecutorRegistration { id: Uuid::new_v4().to_string(), // assign this executor a unique ID - optional_host: None, + optional_host: Some(OptionalHost::Host("localhost".to_string())), port: addr.port() as u32, }; tokio::spawn(execution_loop::poll_loop(