diff --git a/sdks/python/apache_beam/utils/subprocess_server.py b/sdks/python/apache_beam/utils/subprocess_server.py index b8668c2b61b0..944c12625d7c 100644 --- a/sdks/python/apache_beam/utils/subprocess_server.py +++ b/sdks/python/apache_beam/utils/subprocess_server.py @@ -385,7 +385,8 @@ def local_jar(cls, url, cache_dir=None): os.rename(cached_jar + '.tmp', cached_jar) except URLError as e: raise RuntimeError( - 'Unable to fetch remote job server jar at %s: %s' % (url, e)) + f'Unable to fetch remote job server jar at {url}: {e}. If no ' + f'Internet access at runtime, stage the jar at {cached_jar}') return cached_jar @classmethod