test

miraisolutions · Oct 28, 2024 · bd03037 · bd03037
1 parent 43baa4b
commit bd03037
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git 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
@@ -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
@@ -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",