fix typos in pyspark dataproc job resource (#1120)

This commit is contained in:
Dana Hoffman 2018-03-01 18:02:33 -08:00 committed by GitHub
parent d73d1fd576
commit 263240dd9f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -461,16 +461,16 @@ func expandPySparkJob(config map[string]interface{}) *dataproc.PySparkJob {
job.Args = convertStringArr(v.([]interface{}))
}
if v, ok := config["python_file_uris"]; ok {
job.Args = convertStringArr(v.([]interface{}))
job.PythonFileUris = convertStringArr(v.([]interface{}))
}
if v, ok := config["jar_file_uris"]; ok {
job.Args = convertStringArr(v.([]interface{}))
job.JarFileUris = convertStringArr(v.([]interface{}))
}
if v, ok := config["file_uris"]; ok {
job.Args = convertStringArr(v.([]interface{}))
job.FileUris = convertStringArr(v.([]interface{}))
}
if v, ok := config["archive_uris"]; ok {
job.Args = convertStringArr(v.([]interface{}))
job.ArchiveUris = convertStringArr(v.([]interface{}))
}
if v, ok := config["properties"]; ok {
job.Properties = convertStringMap(v.(map[string]interface{}))