From 75c135058bda269ddf9f175b2fdb56fa6c6da0c6 Mon Sep 17 00:00:00 2001 From: Vitaly Terentyev Date: Fri, 21 Mar 2025 15:11:25 +0400 Subject: [PATCH 1/2] Fix address in expansion service --- .../apache_beam/runners/portability/expansion_service_main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/portability/expansion_service_main.py b/sdks/python/apache_beam/runners/portability/expansion_service_main.py index 6b89cee6082e..307f6bd54182 100644 --- a/sdks/python/apache_beam/runners/portability/expansion_service_main.py +++ b/sdks/python/apache_beam/runners/portability/expansion_service_main.py @@ -55,7 +55,7 @@ def main(argv): with fully_qualified_named_transform.FullyQualifiedNamedTransform.with_filter( known_args.fully_qualified_name_glob): - address = 'localhost:{}'.format(known_args.port) + address = '[::]:{}'.format(known_args.port) server = grpc.server(thread_pool_executor.shared_unbounded_instance()) if known_args.serve_loopback_worker: beam_fn_api_pb2_grpc.add_BeamFnExternalWorkerPoolServicer_to_server( From bc7fe9915b4178913b99ac7f3a102f3f849655a3 Mon Sep 17 00:00:00 2001 From: Vitaly Terentyev Date: Fri, 21 Mar 2025 17:13:52 +0400 Subject: [PATCH 2/2] Change address to 0.0.0.0 --- .../apache_beam/runners/portability/expansion_service_main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/portability/expansion_service_main.py b/sdks/python/apache_beam/runners/portability/expansion_service_main.py index 307f6bd54182..269d02b3efbd 100644 --- a/sdks/python/apache_beam/runners/portability/expansion_service_main.py +++ b/sdks/python/apache_beam/runners/portability/expansion_service_main.py @@ -55,7 +55,7 @@ def main(argv): with fully_qualified_named_transform.FullyQualifiedNamedTransform.with_filter( known_args.fully_qualified_name_glob): - address = '[::]:{}'.format(known_args.port) + address = '0.0.0.0:{}'.format(known_args.port) server = grpc.server(thread_pool_executor.shared_unbounded_instance()) if known_args.serve_loopback_worker: beam_fn_api_pb2_grpc.add_BeamFnExternalWorkerPoolServicer_to_server(