You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Hyukjin Kwon (Jira)" <ji...@apache.org> on 2020/07/14 01:30:00 UTC
[jira] [Updated] (SPARK-32296) Flaky Test: submit a barrier ResultStage that requires more slots than current total under local-cluster mode

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

Hyukjin Kwon updated SPARK-32296:
---------------------------------
    Component/s: Spark Core

> Flaky Test: submit a barrier ResultStage that requires more slots than current total under local-cluster mode
> -------------------------------------------------------------------------------------------------------------
>
>                 Key: SPARK-32296
>                 URL: https://issues.apache.org/jira/browse/SPARK-32296
>             Project: Spark
>          Issue Type: Sub-task
>          Components: Spark Core, Tests
>    Affects Versions: 3.1.0
>            Reporter: Hyukjin Kwon
>            Priority: Major
>
> {code}
> 2020-07-13T21:39:28.3795362Z [0m[[0minfo[0m] [0m[31m- submit a barrier ResultStage that requires more slots than current total under local-cluster mode *** FAILED *** (5 seconds, 703 milliseconds)[0m[0m
> 2020-07-13T21:39:28.3843780Z [0m[[0minfo[0m] [0m[31m  Expected exception org.apache.spark.SparkException to be thrown, but java.util.concurrent.TimeoutException was thrown (BarrierStageOnSubmittedSuite.scala:53)[0m[0m
> 2020-07-13T21:39:28.3844344Z [0m[[0minfo[0m] [0m[31m  org.scalatest.exceptions.TestFailedException:[0m[0m
> 2020-07-13T21:39:28.4058689Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Assertions.newAssertionFailedException(Assertions.scala:530)[0m[0m
> 2020-07-13T21:39:28.4059209Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Assertions.newAssertionFailedException$(Assertions.scala:529)[0m[0m
> 2020-07-13T21:39:28.4175876Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuite.newAssertionFailedException(FunSuite.scala:1560)[0m[0m
> 2020-07-13T21:39:28.4176563Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Assertions.intercept(Assertions.scala:814)[0m[0m
> 2020-07-13T21:39:28.4176967Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Assertions.intercept$(Assertions.scala:804)[0m[0m
> 2020-07-13T21:39:28.4177353Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuite.intercept(FunSuite.scala:1560)[0m[0m
> 2020-07-13T21:39:28.4177794Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.BarrierStageOnSubmittedSuite.testSubmitJob(BarrierStageOnSubmittedSuite.scala:53)[0m[0m
> 2020-07-13T21:39:28.4178272Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.BarrierStageOnSubmittedSuite.$anonfun$new$35(BarrierStageOnSubmittedSuite.scala:240)[0m[0m
> 2020-07-13T21:39:28.4178695Z [0m[[0minfo[0m] [0m[31m  at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)[0m[0m
> 2020-07-13T21:39:28.4179081Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)[0m[0m
> 2020-07-13T21:39:28.4179731Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)[0m[0m
> 2020-07-13T21:39:28.4180162Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)[0m[0m
> 2020-07-13T21:39:28.4180550Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Transformer.apply(Transformer.scala:22)[0m[0m
> 2020-07-13T21:39:28.4180929Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Transformer.apply(Transformer.scala:20)[0m[0m
> 2020-07-13T21:39:28.4181323Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike$$anon$1.apply(FunSuiteLike.scala:186)[0m[0m
> 2020-07-13T21:39:28.4181728Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.withFixture(SparkFunSuite.scala:157)[0m[0m
> 2020-07-13T21:39:28.4223205Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.invokeWithFixture$1(FunSuiteLike.scala:184)[0m[0m
> 2020-07-13T21:39:28.4223689Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.$anonfun$runTest$1(FunSuiteLike.scala:196)[0m[0m
> 2020-07-13T21:39:28.4224119Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.runTestImpl(Engine.scala:286)[0m[0m
> 2020-07-13T21:39:28.4224510Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.runTest(FunSuiteLike.scala:196)[0m[0m
> 2020-07-13T21:39:28.4224901Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.runTest$(FunSuiteLike.scala:178)[0m[0m
> 2020-07-13T21:39:28.4225362Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.org$scalatest$BeforeAndAfterEach$$super$runTest(SparkFunSuite.scala:59)[0m[0m
> 2020-07-13T21:39:28.4225778Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterEach.runTest(BeforeAndAfterEach.scala:221)[0m[0m
> 2020-07-13T21:39:28.4226188Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterEach.runTest$(BeforeAndAfterEach.scala:214)[0m[0m
> 2020-07-13T21:39:28.4226589Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.runTest(SparkFunSuite.scala:59)[0m[0m
> 2020-07-13T21:39:28.4226997Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.$anonfun$runTests$1(FunSuiteLike.scala:229)[0m[0m
> 2020-07-13T21:39:28.4227685Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:393)[0m[0m
> 2020-07-13T21:39:28.4228069Z [0m[[0minfo[0m] [0m[31m  at scala.collection.immutable.List.foreach(List.scala:392)[0m[0m
> 2020-07-13T21:39:28.4228461Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:381)[0m[0m
> 2020-07-13T21:39:28.4228850Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:376)[0m[0m
> 2020-07-13T21:39:28.4229236Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:458)[0m[0m
> 2020-07-13T21:39:28.4229651Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.runTests(FunSuiteLike.scala:229)[0m[0m
> 2020-07-13T21:39:28.4230044Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.runTests$(FunSuiteLike.scala:228)[0m[0m
> 2020-07-13T21:39:28.4230439Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuite.runTests(FunSuite.scala:1560)[0m[0m
> 2020-07-13T21:39:28.4230811Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Suite.run(Suite.scala:1124)[0m[0m
> 2020-07-13T21:39:28.4231190Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Suite.run$(Suite.scala:1106)[0m[0m
> 2020-07-13T21:39:28.4231621Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1560)[0m[0m
> 2020-07-13T21:39:28.4232025Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.$anonfun$run$1(FunSuiteLike.scala:233)[0m[0m
> 2020-07-13T21:39:28.4232410Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.runImpl(Engine.scala:518)[0m[0m
> 2020-07-13T21:39:28.4232796Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.run(FunSuiteLike.scala:233)[0m[0m
> 2020-07-13T21:39:28.4233181Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.run$(FunSuiteLike.scala:232)[0m[0m
> 2020-07-13T21:39:28.4233712Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.org$scalatest$BeforeAndAfterAll$$super$run(SparkFunSuite.scala:59)[0m[0m
> 2020-07-13T21:39:28.4234154Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213)[0m[0m
> 2020-07-13T21:39:28.4234559Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)[0m[0m
> 2020-07-13T21:39:28.4234960Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208)[0m[0m
> 2020-07-13T21:39:28.4235346Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.run(SparkFunSuite.scala:59)[0m[0m
> 2020-07-13T21:39:28.4235783Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:317)[0m[0m
> 2020-07-13T21:39:28.4236192Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:510)[0m[0m
> 2020-07-13T21:39:28.4236568Z [0m[[0minfo[0m] [0m[31m  at sbt.ForkMain$Run$2.call(ForkMain.java:296)[0m[0m
> 2020-07-13T21:39:28.4236944Z [0m[[0minfo[0m] [0m[31m  at sbt.ForkMain$Run$2.call(ForkMain.java:286)[0m[0m
> 2020-07-13T21:39:28.4237333Z [0m[[0minfo[0m] [0m[31m  at java.util.concurrent.FutureTask.run(FutureTask.java:266)[0m[0m
> 2020-07-13T21:39:28.4237765Z [0m[[0minfo[0m] [0m[31m  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[0m[0m
> 2020-07-13T21:39:28.4238183Z [0m[[0minfo[0m] [0m[31m  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[0m[0m
> 2020-07-13T21:39:28.4238550Z [0m[[0minfo[0m] [0m[31m  at java.lang.Thread.run(Thread.java:748)[0m[0m
> 2020-07-13T21:39:28.4302636Z [0m[[0minfo[0m] [0m[31m  Cause: java.util.concurrent.TimeoutException: Futures timed out after [5 seconds][0m[0m
> 2020-07-13T21:39:28.4303484Z [0m[[0minfo[0m] [0m[31m  at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:259)[0m[0m
> 2020-07-13T21:39:28.4309405Z [0m[[0minfo[0m] [0m[31m  at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:187)[0m[0m
> 2020-07-13T21:39:28.4309853Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SimpleFutureAction.result(FutureAction.scala:130)[0m[0m
> 2020-07-13T21:39:28.4310262Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.util.ThreadUtils$.awaitResult(ThreadUtils.scala:294)[0m[0m
> 2020-07-13T21:39:28.4310729Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.BarrierStageOnSubmittedSuite.$anonfun$testSubmitJob$5(BarrierStageOnSubmittedSuite.scala:54)[0m[0m
> 2020-07-13T21:39:28.4311133Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Assertions.intercept(Assertions.scala:807)[0m[0m
> 2020-07-13T21:39:28.4311540Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Assertions.intercept$(Assertions.scala:804)[0m[0m
> 2020-07-13T21:39:28.4311925Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuite.intercept(FunSuite.scala:1560)[0m[0m
> 2020-07-13T21:39:28.4312373Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.BarrierStageOnSubmittedSuite.testSubmitJob(BarrierStageOnSubmittedSuite.scala:53)[0m[0m
> 2020-07-13T21:39:28.4312831Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.BarrierStageOnSubmittedSuite.$anonfun$new$35(BarrierStageOnSubmittedSuite.scala:240)[0m[0m
> 2020-07-13T21:39:28.4313245Z [0m[[0minfo[0m] [0m[31m  at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)[0m[0m
> 2020-07-13T21:39:28.4313645Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85)[0m[0m
> 2020-07-13T21:39:28.4314028Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83)[0m[0m
> 2020-07-13T21:39:28.4314415Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)[0m[0m
> 2020-07-13T21:39:28.4314797Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Transformer.apply(Transformer.scala:22)[0m[0m
> 2020-07-13T21:39:28.4315316Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Transformer.apply(Transformer.scala:20)[0m[0m
> 2020-07-13T21:39:28.4315756Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike$$anon$1.apply(FunSuiteLike.scala:186)[0m[0m
> 2020-07-13T21:39:28.4316158Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.withFixture(SparkFunSuite.scala:157)[0m[0m
> 2020-07-13T21:39:28.4316565Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.invokeWithFixture$1(FunSuiteLike.scala:184)[0m[0m
> 2020-07-13T21:39:28.4316970Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.$anonfun$runTest$1(FunSuiteLike.scala:196)[0m[0m
> 2020-07-13T21:39:28.4317355Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.runTestImpl(Engine.scala:286)[0m[0m
> 2020-07-13T21:39:28.4317760Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.runTest(FunSuiteLike.scala:196)[0m[0m
> 2020-07-13T21:39:28.4318151Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.runTest$(FunSuiteLike.scala:178)[0m[0m
> 2020-07-13T21:39:28.4318599Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.org$scalatest$BeforeAndAfterEach$$super$runTest(SparkFunSuite.scala:59)[0m[0m
> 2020-07-13T21:39:28.4319017Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterEach.runTest(BeforeAndAfterEach.scala:221)[0m[0m
> 2020-07-13T21:39:28.4319424Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterEach.runTest$(BeforeAndAfterEach.scala:214)[0m[0m
> 2020-07-13T21:39:28.4319838Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.runTest(SparkFunSuite.scala:59)[0m[0m
> 2020-07-13T21:39:28.4320240Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.$anonfun$runTests$1(FunSuiteLike.scala:229)[0m[0m
> 2020-07-13T21:39:28.4320645Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.$anonfun$runTestsInBranch$1(Engine.scala:393)[0m[0m
> 2020-07-13T21:39:28.4321028Z [0m[[0minfo[0m] [0m[31m  at scala.collection.immutable.List.foreach(List.scala:392)[0m[0m
> 2020-07-13T21:39:28.4321425Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:381)[0m[0m
> 2020-07-13T21:39:28.4321915Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.runTestsInBranch(Engine.scala:376)[0m[0m
> 2020-07-13T21:39:28.4322303Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:458)[0m[0m
> 2020-07-13T21:39:28.4322690Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.runTests(FunSuiteLike.scala:229)[0m[0m
> 2020-07-13T21:39:28.4323080Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.runTests$(FunSuiteLike.scala:228)[0m[0m
> 2020-07-13T21:39:28.4323457Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuite.runTests(FunSuite.scala:1560)[0m[0m
> 2020-07-13T21:39:28.4323841Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Suite.run(Suite.scala:1124)[0m[0m
> 2020-07-13T21:39:28.4324213Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.Suite.run$(Suite.scala:1106)[0m[0m
> 2020-07-13T21:39:28.4324631Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1560)[0m[0m
> 2020-07-13T21:39:28.4325037Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.$anonfun$run$1(FunSuiteLike.scala:233)[0m[0m
> 2020-07-13T21:39:28.4325422Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.SuperEngine.runImpl(Engine.scala:518)[0m[0m
> 2020-07-13T21:39:28.4325824Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.run(FunSuiteLike.scala:233)[0m[0m
> 2020-07-13T21:39:28.4326209Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.FunSuiteLike.run$(FunSuiteLike.scala:232)[0m[0m
> 2020-07-13T21:39:28.4326643Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.org$scalatest$BeforeAndAfterAll$$super$run(SparkFunSuite.scala:59)[0m[0m
> 2020-07-13T21:39:28.4327060Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:213)[0m[0m
> 2020-07-13T21:39:28.4327462Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)[0m[0m
> 2020-07-13T21:39:28.4327930Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208)[0m[0m
> 2020-07-13T21:39:28.4328338Z [0m[[0minfo[0m] [0m[31m  at org.apache.spark.SparkFunSuite.run(SparkFunSuite.scala:59)[0m[0m
> 2020-07-13T21:39:28.4328764Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:317)[0m[0m
> 2020-07-13T21:39:28.4329170Z [0m[[0minfo[0m] [0m[31m  at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:510)[0m[0m
> 2020-07-13T21:39:28.4329562Z [0m[[0minfo[0m] [0m[31m  at sbt.ForkMain$Run$2.call(ForkMain.java:296)[0m[0m
> 2020-07-13T21:39:28.4329934Z [0m[[0minfo[0m] [0m[31m  at sbt.ForkMain$Run$2.call(ForkMain.java:286)[0m[0m
> 2020-07-13T21:39:28.4330320Z [0m[[0minfo[0m] [0m[31m  at java.util.concurrent.FutureTask.run(FutureTask.java:266)[0m[0m
> 2020-07-13T21:39:28.4330739Z [0m[[0minfo[0m] [0m[31m  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[0m[0m
> 2020-07-13T21:39:28.4331162Z [0m[[0minfo[0m] [0m[31m  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[0m[0m
> 2020-07-13T21:39:28.4331524Z [0m[[0minfo[0m] [0m[31m  at java.lang.Thread.run(Thread.java:748)[0m[0m
> 2020-07-13T21:39:28.5223212Z java.util.concurrent.RejectedExecutionException: Task scala.concurrent.impl.CallbackRunnable@148c01f6 rejected from java.util.concurrent.ThreadPoolExecutor@448e22db[Shutting down, pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 0]
> 2020-07-13T21:39:28.5223598Z 	at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)
> 2020-07-13T21:39:28.5223795Z 	at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)
> 2020-07-13T21:39:28.5224000Z 	at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)
> 2020-07-13T21:39:28.5224222Z 	at java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668)
> 2020-07-13T21:39:28.5224626Z 	at scala.concurrent.impl.ExecutionContextImpl$$anon$4.execute(ExecutionContextImpl.scala:138)
> 2020-07-13T21:39:28.5224809Z 	at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:72)
> 2020-07-13T21:39:28.5224989Z 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:288)
> 2020-07-13T21:39:28.5225189Z 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:288)
> 2020-07-13T21:39:28.5225373Z 	at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:288)
> 2020-07-13T21:39:28.5225551Z 	at scala.concurrent.Promise.complete(Promise.scala:53)
> 2020-07-13T21:39:28.5225722Z 	at scala.concurrent.Promise.complete$(Promise.scala:52)
> 2020-07-13T21:39:28.5225893Z 	at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:187)
> 2020-07-13T21:39:28.5226088Z 	at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
> 2020-07-13T21:39:28.5226266Z 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
> 2020-07-13T21:39:28.5226448Z 	at scala.concurrent.BatchingExecutor$Batch.processBatch$1(BatchingExecutor.scala:67)
> 2020-07-13T21:39:28.5226629Z 	at scala.concurrent.BatchingExecutor$Batch.$anonfun$run$1(BatchingExecutor.scala:82)
> 2020-07-13T21:39:28.5226807Z 	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
> 2020-07-13T21:39:28.5226984Z 	at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:85)
> 2020-07-13T21:39:28.5227173Z 	at scala.concurrent.BatchingExecutor$Batch.run(BatchingExecutor.scala:59)
> 2020-07-13T21:39:28.5227373Z 	at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:875)
> 2020-07-13T21:39:28.5227554Z 	at scala.concurrent.BatchingExecutor.execute(BatchingExecutor.scala:110)
> 2020-07-13T21:39:28.5227730Z 	at scala.concurrent.BatchingExecutor.execute$(BatchingExecutor.scala:107)
> 2020-07-13T21:39:28.5227907Z 	at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:873)
> 2020-07-13T21:39:28.5228184Z 	at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:72)
> 2020-07-13T21:39:28.5228368Z 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:288)
> 2020-07-13T21:39:28.5228555Z 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:288)
> 2020-07-13T21:39:28.5228736Z 	at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:288)
> 2020-07-13T21:39:28.5228909Z 	at scala.concurrent.Promise.complete(Promise.scala:53)
> 2020-07-13T21:39:28.5229077Z 	at scala.concurrent.Promise.complete$(Promise.scala:52)
> 2020-07-13T21:39:28.5229265Z 	at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:187)
> 2020-07-13T21:39:28.5229441Z 	at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
> 2020-07-13T21:39:28.5229617Z 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
> 2020-07-13T21:39:28.5229797Z 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2020-07-13T21:39:28.5229986Z 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2020-07-13T21:39:28.5230178Z 	at java.lang.Thread.run(Thread.java:748)
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org