checkForRemoteErrors (val): узлы выдавали ошибки;все соединения используются

Question

Выполнение этого вызова для parLapply

cl <- makeCluster(n_division)

parLapply(cl,
      seq(1, 22),

      function(indice){
        data <- readRDS("data.rds")
        liste <- unique(data$identif)
        lapply(liste,
                 function(id){
                   print(id)
                   df_id <- data %>%
                     filter(identif == id)
                   name_file <- "result.rds"
                   tryCatch({
                       result_df <<- MYFUNCTION(df_id)  ==> **This function return ERROR**
                       saveRDS(result_df , name_file )
                    }, error = function(err){
                       log_message(err)
                    })
                 }
             )
 })

stopCluster(cl)

вызывает эту ошибку

22 узла выдают ошибки;Первая ошибка: все соединения используются

Вызовы: source ... clusterApply -> staticClusterApply -> checkForRemoteErrors

Выполнение остановлено

у кого-то уже была такая же ошибка

Answer 1

cl <- makeCluster(n_division)

parLapply(cl,
          seq(1, 22),

          function(indice){
            data <- readRDS("data.rds")
            liste <- unique(data$identif)
            lapply(liste ,
                     function(id){
                       print(id)
                       df_id <- data %>%
                         filter(identif == id)
                       name_file <- "result.rds"
                       tryCatch({
                           result_df <<- MYFUNCTION(df_id)  ==> **This function return ERROR**
                           saveRDS(result_df , name_file )
                        }, error = function(err){
                           log_message(err)
                        })
             }
                 )
 })

stopCluster(cl)