add entrypoint to cluster config

ytsaurus · Dec 31, 2024 · e9c92ee · e9c92ee
1 parent 0739dbb
commit e9c92ee
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/spyt-package/src/main/python/spyt/spec.py b/spyt-package/src/main/python/spyt/spec.py
@@ -161,6 +161,8 @@ def _launcher_command(component: str, common_params: CommonSpecParams, additiona
                                         additional_parameters)
 
     java_bin = os.path.join(common_params.java_home, 'bin', 'java')
+    if entrypoint := common_params.config['entrypoint']:
+        java_bin = f'{entrypoint} {java_bin}'
     classpath = (f'{common_params.spark_home}/spyt-package/conf/:'
                  f'{common_params.spark_home}/spyt-package/jars/*:'
                  f'{common_params.spark_home}/spark/jars/*')