diff --git a/components/dataproc/common/_utils.py b/components/dataproc/common/_utils.py index 110afb2e1cb..2ad2ecf35c4 100644 --- a/components/dataproc/common/_utils.py +++ b/components/dataproc/common/_utils.py @@ -34,6 +34,9 @@ def create_cluster(api, project, region, cluster_name, init_file_url): 'config': { 'gceClusterConfig': { }, + 'softwareConfig': { + 'imageVersion': '1.2' + }, 'initializationActions': { 'executableFile': init_file_url }