[ 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-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org