Running ‘testthat.R’ [116s/277s]
Running the tests in ‘tests/testthat.R’ failed.
Complete output:
  > library(testthat)
  > library(parsnip)
  > 
  > test_check("parsnip")
  ── 1. Failure: spark execution (@test_boost_tree_spark.R#52)  ──────────────────
  `spark_reg_pred <- predict(spark_reg_fit, hpc_bt_te)` threw an error.
  Message: java.lang.IllegalArgumentException: Field "compounds" does not exist.
  Available fields: input_fields, iterations, num_pending, class
  	at org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:274)
  	at org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:274)
  	at scala.collection.MapLike$class.getOrElse(MapLike.scala:128)
  	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
  	at org.apache.spark.sql.types.StructType.apply(StructType.scala:273)
  	at org.apache.spark.ml.feature.VectorAssembler$$anonfun$6.apply(VectorAssembler.scala:162)
  	at org.apache.spark.ml.feature.VectorAssembler$$anonfun$6.apply(VectorAssembler.scala:161)
  	at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
  	at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
  	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
  	at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)
  	at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
  	at scala.collection.mutable.ArrayOps$ofRef.flatMap(ArrayOps.scala:186)
  	at org.apache.spark.ml.feature.VectorAssembler.transformSchema(VectorAssembler.scala:161)
  	at org.apache.spark.ml.PipelineModel$$anonfun$transformSchema$5.apply(Pipeline.scala:311)
  	at org.apache.spark.ml.PipelineModel$$anonfun$transformSchema$5.apply(Pipeline.scala:311)
  	at scala.collection.IndexedSeqOptimized$class.foldl(IndexedSeqOptimized.scala:57)
  	at scala.collection.IndexedSeqOptimized$class.foldLeft(IndexedSeqOptimized.scala:66)
  	at scala.collection.mutable.ArrayOps$ofRef.foldLeft(ArrayOps.scala:186)
  	at org.apache.spark.ml.PipelineModel.transformSchema(Pipeline.scala:311)
  	at org.apache.spark.ml.feature.RFormulaModel.transformSchema(RFormula.scala:349)
  	at org.apache.spark.ml.PipelineModel$$anonfun$transformSchema$5.apply(Pipeline.scala:311)
  	at org.apache.spark.ml.PipelineModel$$anonfun$transformSchema$5.apply(Pipeline.scala:311)
  	at scala.collection.IndexedSeqOptimized$class.foldl(IndexedSeqOptimized.scala:57)
  	at scala.collection.IndexedSeqOptimized$class.foldLeft(IndexedSeqOptimized.scala:66)
  	at scala.collection.mutable.ArrayOps$ofRef.foldLeft(ArrayOps.scala:186)
  	at org.apache.spark.ml.PipelineModel.transformSchema(Pipeline.scala:311)
  	at org.apache.spark.ml.PipelineStage.transformSchema(Pipeline.scala:74)
  	at org.apache.spark.ml.PipelineModel.transform(Pipeline.scala:305)
  	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  	at java.lang.reflect.Method.invoke(Method.java:498)
  	at sparklyr.Invoke.invoke(invoke.scala:147)
  	at sparklyr.StreamHandler.handleMethodCall(stream.scala:136)
  	at sparklyr.StreamHandler.read(stream.scala:61)
  	at sparklyr.BackendHandler$$anonfun$channelRead0$1.apply$mcV$sp(handler.scala:58)
  	at scala.util.control.Breaks.breakable(Breaks.scala:38)
  	at sparklyr.BackendHandler.channelRead0(handler.scala:38)
  	at sparklyr.BackendHandler.channelRead0(handler.scala:14)
  	at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:321)
  	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:295)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
  	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
  	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
  	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
  	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  	at java.lang.Thread.run(Thread.java:748)
  
  Class:   simpleError/error/condition
  Backtrace:
    1. testthat::expect_error(...)
   12. sparklyr:::ml_predict.ml_model_regression(x = object$fit, dataset = new_data)
    3. x$pipeline_model
   10. sparklyr::ml_transform(., dataset)
    5. sparklyr::spark_jobj(x)
   12. sparklyr::invoke(., "transform", sdf)
   32. sparklyr:::invoke_method.spark_shell_connection(...)
   33. sparklyr:::core_invoke_method(sc, static, object, method, ...)
   34. sparklyr:::core_invoke_method_impl(...)
   35. withr::with_options(...)
   36. base::force(code)
  
  ── 2. Failure: spark execution (@test_boost_tree_spark.R#57)  ──────────────────
  `... <- NULL` threw an error.
  Message: java.lang.IllegalArgumentException: Field "compounds" does not exist.
  Available fields: input_fields, iterations, num_pending, class
  	at org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:274)
  	at org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:274)
  	at scala.collection.MapLike$class.getOrElse(MapLike.scala:128)
  	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
  	at org.apache.spark.sql.types.StructType.apply(StructType.scala:273)
  	at org.apache.spark.ml.feature.VectorAssembler$$anonfun$6.apply(VectorAssembler.scala:162)
  	at org.apache.spark.ml.feature.VectorAssembler$$anonfun$6.apply(VectorAssembler.scala:161)
  	at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
  	at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241)
  	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
  	at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186)
  	at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
  	at scala.collection.mutable.ArrayOps$ofRef.flatMap(ArrayOps.scala:186)
  	at org.apache.spark.ml.feature.VectorAssembler.transformSchema(VectorAssembler.scala:161)
  	at org.apache.spark.ml.PipelineModel$$anonfun$transformSchema$5.apply(Pipeline.scala:311)
  	at org.apache.spark.ml.PipelineModel$$anonfun$transformSchema$5.apply(Pipeline.scala:311)
  	at scala.collection.IndexedSeqOptimized$class.foldl(IndexedSeqOptimized.scala:57)
  	at scala.collection.IndexedSeqOptimized$class.foldLeft(IndexedSeqOptimized.scala:66)
  	at scala.collection.mutable.ArrayOps$ofRef.foldLeft(ArrayOps.scala:186)
  	at org.apache.spark.ml.PipelineModel.transformSchema(Pipeline.scala:311)
  	at org.apache.spark.ml.feature.RFormulaModel.transformSchema(RFormula.scala:349)
  	at org.apache.spark.ml.PipelineModel$$anonfun$transformSchema$5.apply(Pipeline.scala:311)
  	at org.apache.spark.ml.PipelineModel$$anonfun$transformSchema$5.apply(Pipeline.scala:311)
  	at scala.collection.IndexedSeqOptimized$class.foldl(IndexedSeqOptimized.scala:57)
  	at scala.collection.IndexedSeqOptimized$class.foldLeft(IndexedSeqOptimized.scala:66)
  	at scala.collection.mutable.ArrayOps$ofRef.foldLeft(ArrayOps.scala:186)
  	at org.apache.spark.ml.PipelineModel.transformSchema(Pipeline.scala:311)
  	at org.apache.spark.ml.PipelineStage.transformSchema(Pipeline.scala:74)
  	at org.apache.spark.ml.PipelineModel.transform(Pipeline.scala:305)
  	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  	at java.lang.reflect.Method.invoke(Method.java:498)
  	at sparklyr.Invoke.invoke(invoke.scala:147)
  	at sparklyr.StreamHandler.handleMethodCall(stream.scala:136)
  	at sparklyr.StreamHandler.read(stream.scala:61)
  	at sparklyr.BackendHandler$$anonfun$channelRead0$1.apply$mcV$sp(handler.scala:58)
  	at scala.util.control.Breaks.breakable(Breaks.scala:38)
  	at sparklyr.BackendHandler.channelRead0(handler.scala:38)
  	at sparklyr.BackendHandler.channelRead0(handler.scala:14)
  	at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:321)
  	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:295)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
  	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
  	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
  	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
  	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  	at java.lang.Thread.run(Thread.java:748)
  
  Class:   simpleError/error/condition
  Backtrace:
    1. testthat::expect_error(...)
    9. sparklyr:::ml_predict.ml_model_regression(x = object$fit, dataset = new_data)
    3. x$pipeline_model
   10. sparklyr::ml_transform(., dataset)
    5. sparklyr::spark_jobj(x)
   12. sparklyr::invoke(., "transform", sdf)
   29. sparklyr:::invoke_method.spark_shell_connection(...)
   30. sparklyr:::core_invoke_method(sc, static, object, method, ...)
   31. sparklyr:::core_invoke_method_impl(...)
   32. withr::with_options(...)
   33. base::force(code)
  
  ── 3. Error: spark execution (@test_boost_tree_spark.R#72)  ────────────────────
  object 'spark_reg_pred' not found
  Backtrace:
   1. testthat::expect_equal(colnames(spark_reg_pred), "pred")
   4. base::colnames(spark_reg_pred)
   5. base::is.data.frame(x)
  
  OMP: Warning #96: Cannot form a team with 24 threads, using 2 instead.
  OMP: Hint Consider unsetting KMP_DEVICE_THREAD_LIMIT (KMP_ALL_THREADS), KMP_TEAMS_THREAD_LIMIT, and OMP_THREAD_LIMIT (if any are set).
  ── 4. Failure: spark descriptor (@test_descriptors.R#205)  ─────────────────────
  template2(5, 4, 150, NA, 1) not equal to eval_descrs2(get_descr_form(Sepal_Width ~ ., data = hpc_descr)).
  Component ".cols": Mean relative difference: 0.4
  Component ".preds": Mean relative difference: 0.25
  
  ── 5. Error: spark descriptor (@test_descriptors.R#209)  ───────────────────────
  Can't subset columns that don't exist.
  ✖ Column `Sepal_Width` doesn't exist.
  Backtrace:
    1. testthat::expect_equal(...)
    7. parsnip:::get_descr_form(Sepal_Width ~ class, data = hpc_descr)
    8. parsnip:::get_descr_spark(formula, data)
   10. dbplyr:::select.tbl_lazy(data, !!!rlang::syms(f_cols))
   11. tidyselect::vars_select(old_vars, !!!dots, .include = op_grps(.data$ops))
   12. tidyselect:::eval_select_impl(...)
   20. tidyselect:::vars_select_eval(...)
   21. tidyselect:::walk_data_tree(expr, data_mask, context_mask)
   22. tidyselect:::eval_c(expr, data_mask, context_mask)
   23. tidyselect:::reduce_sels(node, data_mask, context_mask, init = init)
   24. tidyselect:::walk_data_tree(new, data_mask, context_mask)
   25. tidyselect:::as_indices_sel_impl(...)
   26. tidyselect:::as_indices_impl(x, vars, strict = strict)
   27. tidyselect:::chr_as_locations(x, vars)
   28. vctrs::vec_as_location(x, n = length(vars), names = vars)
   30. vctrs:::stop_subscript_oob(...)
   31. vctrs:::stop_subscript(...)
  
  ── 6. Failure: spark execution (@test_linear_reg_spark.R#26)  ──────────────────
  `... <- NULL` threw an error.
  Message: java.lang.IllegalArgumentException: Field "label" does not exist.
  Available fields: compounds, input_fields, iterations, num_pending, class, features
  	at org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:274)
  	at org.apache.spark.sql.types.StructType$$anonfun$apply$1.apply(StructType.scala:274)
  	at scala.collection.MapLike$class.getOrElse(MapLike.scala:128)
  	at scala.collection.AbstractMap.getOrElse(Map.scala:59)
  	at org.apache.spark.sql.types.StructType.apply(StructType.scala:273)
  	at org.apache.spark.ml.util.SchemaUtils$.checkNumericType(SchemaUtils.scala:74)
  	at org.apache.spark.ml.PredictorParams$class.validateAndTransformSchema(Predictor.scala:53)
  	at org.apache.spark.ml.regression.LinearRegression.org$apache$spark$ml$regression$LinearRegressionParams$$super$validateAndTransformSchema(LinearRegression.scala:177)
  	at org.apache.spark.ml.regression.LinearRegressionParams$class.validateAndTransformSchema(LinearRegression.scala:120)
  	at org.apache.spark.ml.regression.LinearRegression.validateAndTransformSchema(LinearRegression.scala:177)
  	at org.apache.spark.ml.Predictor.transformSchema(Predictor.scala:144)
  	at org.apache.spark.ml.PipelineStage.transformSchema(Pipeline.scala:74)
  	at org.apache.spark.ml.Predictor.fit(Predictor.scala:100)
  	at org.apache.spark.ml.Predictor.fit(Predictor.scala:82)
  	at org.apache.spark.ml.Pipeline$$anonfun$fit$2.apply(Pipeline.scala:153)
  	at org.apache.spark.ml.Pipeline$$anonfun$fit$2.apply(Pipeline.scala:149)
  	at scala.collection.Iterator$class.foreach(Iterator.scala:891)
  	at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
  	at scala.collection.IterableViewLike$Transformed$class.foreach(IterableViewLike.scala:44)
  	at scala.collection.SeqViewLike$AbstractTransformed.foreach(SeqViewLike.scala:37)
  	at org.apache.spark.ml.Pipeline.fit(Pipeline.scala:149)
  	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  	at java.lang.reflect.Method.invoke(Method.java:498)
  	at sparklyr.Invoke.invoke(invoke.scala:147)
  	at sparklyr.StreamHandler.handleMethodCall(stream.scala:136)
  	at sparklyr.StreamHandler.read(stream.scala:61)
  	at sparklyr.BackendHandler$$anonfun$channelRead0$1.apply$mcV$sp(handler.scala:58)
  	at scala.util.control.Breaks.breakable(Breaks.scala:38)
  	at sparklyr.BackendHandler.channelRead0(handler.scala:38)
  	at sparklyr.BackendHandler.channelRead0(handler.scala:14)
  	at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:321)
  	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:295)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
  	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
  	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
  	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)
  	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)
  	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)
  	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
  	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
  	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  	at java.lang.Thread.run(Thread.java:748)
  
  Class:   simpleError/error/condition
  Backtrace:
    1. testthat::expect_error(...)
   13. sparklyr:::ml_linear_regression.tbl_spark(...)
   14. sparklyr::ml_construct_model_supervised(...)
   15. sparklyr::ml_supervised_pipeline(...)
    5. sparklyr::ml_pipeline(r_formula, predictor)
   13. sparklyr::ml_fit(., dataset)
    7. sparklyr::spark_jobj(x)
   14. sparklyr::invoke(., "fit", spark_dataframe(dataset))
   35. sparklyr:::invoke_method.spark_shell_connection(...)
   36. sparklyr:::core_invoke_method(sc, static, object, method, ...)
   37. sparklyr:::core_invoke_method_impl(...)
   38. withr::with_options(...)
   39. base::force(code)
  
  ── 7. Error: spark execution (@test_linear_reg_spark.R#37)  ────────────────────
  object 'spark_fit' not found
  Backtrace:
   1. testthat::expect_false(has_multi_predict(spark_fit))
   4. parsnip::has_multi_predict(spark_fit)
  
  ── 8. Failure: spark execution (@test_multinom_reg_spark.R#67)  ────────────────
  colnames(spark_class_prob) not equal to c("pred_versicolor", "pred_virginica", "pred_setosa").
  Lengths differ: 4 is not 3
  
  ── 9. Failure: spark execution (@test_rand_forest_spark.R#28)  ─────────────────
  `... <- NULL` threw an error.
  Message: `Sepal_Length` is not a column in the input dataset.
  Class:   simpleError/error/condition
  Backtrace:
    1. testthat::expect_error(...)
   12. sparklyr::ml_random_forest(...)
  
  ── 10. Failure: spark execution (@test_rand_forest_spark.R#41)  ────────────────
  `... <- NULL` threw an error.
  Message: `Sepal_Length` is not a column in the input dataset.
  Class:   simpleError/error/condition
  Backtrace:
    1. testthat::expect_error(...)
   12. sparklyr::ml_random_forest(...)
  
  ── 11. Failure: spark execution (@test_rand_forest_spark.R#53)  ────────────────
  `spark_reg_pred <- predict(spark_reg_fit, hpc_rf_te)` threw an error.
  Message: object 'spark_reg_fit' not found
  Class:   simpleError/error/condition
  Backtrace:
   1. testthat::expect_error(...)
   6. stats::predict(spark_reg_fit, hpc_rf_te)
  
  ── 12. Failure: spark execution (@test_rand_forest_spark.R#58)  ────────────────
  `spark_reg_pred_num <- predict(spark_reg_fit, hpc_rf_te)` threw an error.
  Message: object 'spark_reg_fit' not found
  Class:   simpleError/error/condition
  Backtrace:
   1. testthat::expect_error(...)
   6. stats::predict(spark_reg_fit, hpc_rf_te)
  
  ── 13. Failure: spark execution (@test_rand_forest_spark.R#63)  ────────────────
  `spark_reg_dup <- predict(spark_reg_fit_dup, hpc_rf_te)` threw an error.
  Message: object 'spark_reg_fit_dup' not found
  Class:   simpleError/error/condition
  Backtrace:
   1. testthat::expect_error(...)
   6. stats::predict(spark_reg_fit_dup, hpc_rf_te)
  
  ── 14. Failure: spark execution (@test_rand_forest_spark.R#68)  ────────────────
  `spark_reg_num_dup <- predict(spark_reg_fit_dup, hpc_rf_te)` threw an error.
  Message: object 'spark_reg_fit_dup' not found
  Class:   simpleError/error/condition
  Backtrace:
   1. testthat::expect_error(...)
   6. stats::predict(spark_reg_fit_dup, hpc_rf_te)
  
  ── 15. Error: spark execution (@test_rand_forest_spark.R#73)  ──────────────────
  object 'spark_reg_pred' not found
  Backtrace:
   1. testthat::expect_equal(colnames(spark_reg_pred), "pred")
   4. base::colnames(spark_reg_pred)
   5. base::is.data.frame(x)
  
  ══ testthat results  ═══════════════════════════════════════════════════════════
  [ OK: 896 | SKIPPED: 49 | WARNINGS: 1 | FAILED: 15 ]
  1. Failure: spark execution (@test_boost_tree_spark.R#52) 
  2. Failure: spark execution (@test_boost_tree_spark.R#57) 
  3. Error: spark execution (@test_boost_tree_spark.R#72) 
  4. Failure: spark descriptor (@test_descriptors.R#205) 
  5. Error: spark descriptor (@test_descriptors.R#209) 
  6. Failure: spark execution (@test_linear_reg_spark.R#26) 
  7. Error: spark execution (@test_linear_reg_spark.R#37) 
  8. Failure: spark execution (@test_multinom_reg_spark.R#67) 
  9. Failure: spark execution (@test_rand_forest_spark.R#28) 
  1. ...
  
  Error: testthat unit tests failed
  Execution halted