Skip to content

Commit 53826b4

Browse files
authored
Update submit_spark_job_to_driver_node_group_cluster.py
1 parent 0052732 commit 53826b4

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

dataproc/snippets/submit_spark_job_to_driver_node_group_cluster.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,8 @@ def submit_job(project_id: str, region: str, cluster_name: str) -> None:
4444
) as job_client:
4545

4646
driver_scheduling_config = dataproc.DriverSchedulingConfig(
47-
memory_mb=2048, # Example memory in MB
48-
vcores=2, # Example number of vcores
47+
memory_mb=2048, # Example memory in MB
48+
vcores=2, # Example number of vcores
4949
)
5050

5151
# Create the job config. 'main_jar_file_uri' can also be a
@@ -60,7 +60,6 @@ def submit_job(project_id: str, region: str, cluster_name: str) -> None:
6060
"driver_scheduling_config": driver_scheduling_config
6161
}
6262

63-
6463
operation = job_client.submit_job_as_operation(
6564
request={"project_id": project_id, "region": region, "job": job}
6665
)

0 commit comments

Comments
 (0)