你可以从akka的原理架构中获取一些信息
参考: https://akka.io
之前在其他博主的介绍中看到过,感觉意思差不多,上面说这是JobManager和TaskManager之间通信时发送的消息大小的最大值
发件人: 赵一旦
发送时间: 2021-01-14 14:19
收件人: user-zh
主题: Re: Flink webui 查询任务信息报错500
好的,我找到了这个参数。不过这个参数表达啥含义知道吗,我看10MB不是个小数字感觉。
Evan 于2021年1月14日周四 下午1:54写道:
> 有这样一个参数“akka.framesize”
s. 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
>
>
>
>
>
> 发件人: 赵一旦
> 发送时
e 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,开发者工具展示的异常信息如下。
"
想知道这个是什么情况,以及需要调整什么参数呢?
ializedResult);
}
} catch (IOException e) {
return Either.Right(
new AkkaRpcException(
"Failed to serialize the result for RPC call : " +
methodName + '.',
e));
}
}
发件人: 赵一旦
发送时间: 2021-01-14 11:38
收件人: user-zh
主题
报错500,开发者工具展示的异常信息如下。
"
想知道这个是什么情况,以及需要调整什么参数呢?