You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Add --job-args (variable never used) and --spark-submit-opts (variable not exists) for EMR on EC2.
Currently --job-args as well as --spark-submit-opts works only for EMR Serverless:
# application_id indicates EMR Serverless jobifapplication_idisnotNone:
# We require entry-point and job-roleifentry_pointisNoneorjob_roleisNone:
raiseclick.BadArgumentUsage(
"--entry-point and --job-role are required if --application-id is used."
)
ifjob_args:
job_args=job_args.split(",")
emrs=EMRServerless(application_id, job_role, p)
emrs.run_job(
job_name, job_args, spark_submit_opts, wait, show_stdout, s3_logs_uri
)
# cluster_id indicates EMR on EC2 jobifcluster_idisnotNone:
ifjob_args:
job_args=job_args.split(",")
emr=EMREC2(cluster_id, p, job_role)
emr.run_job(job_name, job_args, wait, show_stdout) # add spark_submit_opts
The content you are editing has changed. Please copy your edits and refresh the page.
Add
--job-args
(variable never used) and--spark-submit-opts
(variable not exists) for EMR on EC2.Currently
--job-args
as well as--spark-submit-opts
works only for EMR Serverless:Tasks
The text was updated successfully, but these errors were encountered: