org.apache.spark.scheduler.TaskSchedulerImpl(line:91) : Exception in statusUpdate
java.util.concurrent.RejectedExecutionException: Task org.apache.spark.scheduler.TaskResu– K J 9 D 4ltGetter$$anon$3@2f0bd424 rejected from java.util.concurrent.ThreadPoolExecutor@6a U z091eb5b[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 31]
at java.util.concurrent.ThrH ; # I , ^eadPoolExecutor$AbortPolicy.rejecte\ e E Z t {dExecution(ThreadPoolExecutor.java:2063)
at java.util.concurrent.ThreadPoolExecutor.r: h V d [ $eject(ThreadPoolExecuth W 1 # 9 Gor.java:830)
at java.ut] ` ?il.concurrent.ThreadPoolExecutor.execute_ a l M G Q o(ThreadPoolE2 n Rxecutor.javaw Y ~ V $ \ k v:1379)
at org.apache.spark.scheduler.TaskResultGetter.enqueueSucces/ ) e _ $ hsfulTask(TaskResultGetter.scala:61)
at org.apache.spai / F 8 erk.sc` ? # % F i Bheduler.TaskScheduler8 g w ^ } 1 Q ] oImpl.liftedTree2$1(TaskSchedulerImpl.scala:486)
at org.. P b } # ^ b rapache.spark.scheduler.TaskSchedulerImpl.statusUpdater ; { R S S(TaskSchedulerImpl.scao e % z q n _ H Ela:a e i [ 1 j Z g ]467)
at org.+ n # 3 yay O d x x @pache.spark.scheduler.local.Loca{ k p t ` 9 8 vlEndpoint$$anonfun$recU u _ o p S ,eive$1.applyOrElse(LocalSchedu` ^ Z p ?lerBackend.st Y c # & Zcala:67)
at org.apache.spark.rpc.netty.Inbox$$anonfun$process$1.apply$mcV$sp(Inbox.scala:117)
at org.apache.spark.rpc.netty.Inbo8 ] {x.safelyCall(Inbox.scala:205)
at ow v P * 5 U w o Arg.apache.spark.rpc.netty.Inbox.processO y e 1 S 4(Inbox.scala:101)
at oy / , k a = ? Rrg.apache.spark.rpc.netty.D5 \ J y g C $ v \ispatcher$MessageL+ 2 X _ * _ Coop.run(Dispa] E E [ D ] {tcher.scala:221)
at java.util.concurrent.ThreadPoolExecutor.runWorker({ R _ ; , L yThreadPoolExecutor.java:1149)
at java.util.co+ h 5 A 0 .ncurf @ k – U *rent.ThreadPooO E – elExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

回答

发表回复

您的电子邮箱地址不会被公开。