diff --git a/R/spark_read_bigquery.R b/R/spark_read_bigquery.R index 70b8019..d5d7e3a 100644 --- a/R/spark_read_bigquery.R +++ b/R/spark_read_bigquery.R @@ -102,7 +102,7 @@ spark_read_bigquery <- function(sc, } if (!is.null(datasetId) && !is.null(tableId)) { - path <- sprintf("%s.%s.%s", projectId, datasetId, tableId) + path <- sprintf("%s:%s.%s", projectId, datasetId, tableId) } else if (!is.null(sqlQuery)) { path <- sqlQuery parameters[["viewsEnabled"]] <- "true" diff --git a/R/spark_write_bigquery.R b/R/spark_write_bigquery.R index dc521d7..0fd11a2 100644 --- a/R/spark_write_bigquery.R +++ b/R/spark_write_bigquery.R @@ -75,7 +75,7 @@ spark_write_bigquery <- function(data, parameters <- c( list( parentProject = billingProjectId, - table = sprintf("%s.%s.%s", projectId, datasetId, tableId), + table = sprintf("%s:%s.%s", projectId, datasetId, tableId), writeMethod = "direct" ), additionalParameters diff --git a/tests/testthat/setup.R b/tests/testthat/setup.R index 1e708a1..72f7d45 100644 --- a/tests/testthat/setup.R +++ b/tests/testthat/setup.R @@ -8,7 +8,6 @@ bigquery_defaults( options(spark.version = Sys.getenv("SPARK_VERSION", "3.5")) config <- sparklyr::spark_config() -config$sparklyr.log.invoke <- "TRUE" sc <- sparklyr::spark_connect( master = "local",