Better error for missing java.

iht · Mar 18, 2021 · ee29766 · ee29766
1 parent d04319d
commit ee29766
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/sdks/python/apache_beam/utils/subprocess_server.py b/sdks/python/apache_beam/utils/subprocess_server.py
@@ -161,6 +161,9 @@ class JavaJarServer(SubprocessServer):
       dict(__init__=lambda self: setattr(self, 'replacements', {})))()
 
   def __init__(self, stub_class, path_to_jar, java_arguments):
+    if not shutil.which('java'):
+      raise RuntimeError(
+          'Java must be installed on this system to use this transform/runner.')
     super(JavaJarServer, self).__init__(
         stub_class, ['java', '-jar', path_to_jar] + list(java_arguments))
     self._existing_service = path_to_jar if _is_service_endpoint(