From 4d9f0dc4d828bbd363f9e201e46f69f14f7ffdb2 Mon Sep 17 00:00:00 2001 From: bcantos17 Date: Fri, 17 Oct 2025 12:08:52 -0400 Subject: [PATCH] Added flag for overriding artifact hostname --- .../apache/beam/runners/jobsubmission/JobServerDriver.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java b/runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java index 885e54bfb665..f72b2250f0bb 100644 --- a/runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java +++ b/runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobServerDriver.java @@ -81,6 +81,9 @@ public static class ServerConfiguration { usage = "The job service port. 0 to use a dynamic port. (Default: 8099)") private int port = 8099; + @Option(name = "--artifact-host", usage = "The artifact service host name") + private String artifactHost = "localhost"; + @Option( name = "--artifact-port", usage = "The artifact service port. 0 to use a dynamic port. (Default: 8098)") @@ -264,7 +267,7 @@ private GrpcFnServer createArtifactStagingService() thro } else { Endpoints.ApiServiceDescriptor descriptor = Endpoints.ApiServiceDescriptor.newBuilder() - .setUrl(configuration.host + ":" + configuration.artifactPort) + .setUrl(configuration.artifactHost + ":" + configuration.artifactPort) .build(); server = GrpcFnServer.create(service, descriptor, artifactServerFactory); }