diff --git a/R/spark_read_bigquery.R b/R/spark_read_bigquery.R index f3d7ad6..974b3a1 100644 --- a/R/spark_read_bigquery.R +++ b/R/spark_read_bigquery.R @@ -97,7 +97,7 @@ spark_read_bigquery <- function(sc, ...) { parameters <- c(list(), additionalParameters) if (!is.null(serviceAccountKeyFile)) { - parameters[["credentialsFile"]] = serviceAccountKeyFile + parameters[["credentialsFile"]] = normalizePath(serviceAccountKeyFile, winslash = "/") } if (!is.null(datasetId) && !is.null(tableId)) { diff --git a/R/spark_write_bigquery.R b/R/spark_write_bigquery.R index d808031..cc6f7c1 100644 --- a/R/spark_write_bigquery.R +++ b/R/spark_write_bigquery.R @@ -80,7 +80,7 @@ spark_write_bigquery <- function(data, additionalParameters) if (!is.null(serviceAccountKeyFile)) { - parameters[["credentialsFile"]] = serviceAccountKeyFile + parameters[["credentialsFile"]] = normalizePath(serviceAccountKeyFile, winslash = "/") } spark_write_source(data,