Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
Repro from sparklyr unit test:
library(dplyr) library(sparklyr) library(arrow) sc <- spark_connect(master = "local") hive_type <- tibble::frame_data( ~stype, ~svalue, ~rtype, ~rvalue, ~arrow, "smallint", "1", "integer", "1", "integer", ) spark_query <- hive_type %>% mutate( query = paste0("cast(", svalue, " as ", stype, ") as ", gsub("\\(|\\)", "", stype), "_col") ) %>% pull(query) %>% paste(collapse = ", ") %>% paste("SELECT", .) spark_types <- DBI::dbGetQuery(sc, spark_query) %>% lapply(function(e) class(e)[[1]]) %>% as.character()
Actual: error: Failed to fetch data: invalid data