有这样一个参数“akka.framesize” ,可以在你启动flink的时候加上 或者 在conf/flink-conf.yaml 配置上:

akka.framesize
"10485760b"StringMaximum size of messages which are sent between the JobManager 
and the TaskManagers. If Flink fails because messages exceed this limit, then 
you should increase it. The message size requires a size-unit specifier.

参考:
[1] 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/config.html
 




 
发件人: 赵一旦
发送时间: 2021-01-14 11:38
收件人: user-zh
主题: Flink webui 查询任务信息报错500
报错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>"
 
想知道这个是什么情况,以及需要调整什么参数呢?

回复