apache-flink - Flink : 如何通过 flink 代码设置任务管理器属性
问题描述
我收到错误“原因：java.io.IOException：网络缓冲区数量不足：需要 30 个，但只有 25 个可用。网络缓冲区的总数当前设置为 12945 个，每个 32768 个字节。您可以将此数字增加设置配置键 'taskmanager.network.memory.fraction'、'taskmanager.network.memory.min' 和 'taskmanager.network.memory.max'。”
我正在从 Eclipse 运行这个 flink 代码。我知道如何从 flink-conf.yaml 设置任务管理器属性，但是如果我通过 IDE 运行，我该如何设置。
解决方案
执行DataSet作业时，您需要调用ExecutionEnvironment.createLocalEnvironment(Configuration configuration)以传入自定义Configuration.
执行DataStream作业时，您需要调用StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)以传入自定义Configuration.
推荐阅读
- c# - 如何在 C# 上解析 SOAP 响应？
- python - Django - 我可以在不连接模型的情况下创建序列化程序吗？
- python - 使用 Python 将缺失值的数据读入数组
- php - php防止大浮动舍入
- python - 无法将 termcolor 升级到 1.1.0，因此 Tensorflow 失败
- python - 在 conda 中将 python 从 3.5 更新到 3.6
- python - 如果值第一次出现在另一列中，则 Pandas 列为 True 或 False
- wordpress - WordPress“建立数据库连接时出错”
- python - 使用 Python 在 Jupyter Notebook 中为钟摆设置动画
- spring-boot - 在@Value Spring 注释和资源中给出外部路径