有这样一个参数“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>" 想知道这个是什么情况,以及需要调整什么参数呢?