diff --git a/R/spark_read_bigquery.R b/R/spark_read_bigquery.R index 2896381..64c7148 100644 --- a/R/spark_read_bigquery.R +++ b/R/spark_read_bigquery.R @@ -93,7 +93,7 @@ spark_read_bigquery <- function(sc, ...) { parameters <- c(list(), additionalParameters) if (!is.null(serviceAccountKeyFile)) { - spark_session_config(sc, config = "credentialsFile", value = serviceAccountKeyFile) + sparklyr::spark_session_config(sc, config = "credentialsFile", value = serviceAccountKeyFile) parameters[["credentialsFile"]] = gsub("\\\\", "/", serviceAccountKeyFile) }