报错500,开发者工具展示的异常信息如下。
<Exception on server
side:↵org.apache.flink.runtime.rpc.akka.exceptions.AkkaRpcException:
The method requestJob's result size 19811407 exceeds the maximum size
10485760 .↵ at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.serializeRemoteResultAndVerifySize(AkkaRpcActor.java:363)↵
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$sendAsyncResponse$0(AkkaRpcActor.java:337)↵
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)↵
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)↵
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)↵
at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)↵
at
org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:229)↵
at
java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)↵
at
java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)↵
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)↵
at
java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)↵
at
org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:996)↵
at akka.dispatch.OnComplete.internal(Future.scala:264)↵ at
akka.dispatch.OnComplete.internal(Future.scala:261)↵ at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:191)↵ at
akka.dispatch.japi$CallbackBridge.apply(Future.scala:188)↵ at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)↵ at
org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74)↵
at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44)↵
at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252)↵
at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572)↵ at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22)↵
at
akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21)↵
at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436)↵ at
scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435)↵ at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36)↵ at
akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55)↵
at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91)↵
at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)↵
at
akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91)↵
at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72)↵
at
akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90)↵
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)↵ at
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)↵
at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)↵ at
akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)↵
at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)↵
at
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)↵↵End
of exception on server side>"

想知道这个是什么情况,以及需要调整什么参数呢?

回复