You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@arrow.apache.org by "Neal Richardson (Jira)" <ji...@apache.org> on 2022/10/13 15:44:00 UTC

[jira] [Resolved] (ARROW-17702) [R][CI] Test failure on CentOS 7

     [ https://issues.apache.org/jira/browse/ARROW-17702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Neal Richardson resolved ARROW-17702.
-------------------------------------
      Assignee: Dewey Dunnington
    Resolution: Fixed

The error message is something about UDFs, which I know Dewey made some improvements to recently.

> [R][CI] Test failure on CentOS 7
> --------------------------------
>
>                 Key: ARROW-17702
>                 URL: https://issues.apache.org/jira/browse/ARROW-17702
>             Project: Apache Arrow
>          Issue Type: Bug
>          Components: Continuous Integration, R
>            Reporter: Antoine Pitrou
>            Assignee: Dewey Dunnington
>            Priority: Critical
>             Fix For: 10.0.0
>
>
> Seen on 
> https://github.com/apache/arrow/actions/runs/3043073421/jobs/4901940045#step:5:2625
> {code}
>   + as_arrow_table(mtcars) %>%
>   +   transmute(mpg, mpg_predicted = mtcars_predict_mpg(disp, cyl)) %>%
>   +   collect() %>%
>   +   head()
>   + ## Don't show: 
>   + }) # examplesIf
>   > library(dplyr, warn.conflicts = FALSE)
>   > some_model <- lm(mpg ~ disp + cyl, data = mtcars)
>   > register_scalar_function("mtcars_predict_mpg", function(context, disp, 
>   +     cyl) {
>   +     predict(some_model, newdata = data.frame(disp, cyl))
>   + }, in_type = schema(disp = float64(), cyl = float64()), out_type = float64(), auto_convert = TRUE)
>   > as_arrow_table(mtcars) %>% transmute(mpg, mpg_predicted = mtcars_predict_mpg(disp, 
>   +     cyl)) %>% collect() %>% head()
>   Error in `collect()`:
>   ! NotImplemented: Call to R (resolve scalar user-defined function output data type) from a non-R thread from an unsupported context
>   Backtrace:
>        ▆
>     1. ├─(if (getRversion() >= "3.4") withAutoprint else force)(...)
>     2. │ └─base::source(...)
>     3. │   ├─base::withVisible(eval(ei, envir))
>     4. │   └─base::eval(ei, envir)
>     5. │     └─base::eval(ei, envir)
>     6. ├─... %>% head()
>     7. ├─utils::head(.)
>     8. ├─dplyr::collect(.)
>     9. └─arrow:::collect.arrow_dplyr_query(.)
>    10.   └─base::tryCatch(...)
>    11.     └─base (local) tryCatchList(expr, classes, parentenv, handlers)
>    12.       └─base (local) tryCatchOne(expr, names, parentenv, handlers[[1L]])
>    13.         └─value[[3L]](cond)
>    14.           └─rlang::abort(conditionMessage(e), call = call)
>   Execution halted
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)