Flink:如何通过flink代码设置任务管理器属性-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

Flink:如何通过flink代码设置任务管理器属性

flink小助手 2018-12-13 14:40:34 1693

我收到错误“引起: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中运行,我该如何设置。

IDE 开发工具 Android开发 流计算
分享到
取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:20:42

    执行DataSet作业时,您需要调用ExecutionEnvironment.createLocalEnvironment(Configuration configuration)以传递自定义Configuration。

    0 0
开发与运维
使用钉钉扫一扫加入圈子
+ 订阅

集结各类场景实战经验,助你开发运维畅行无忧

推荐文章
相似问题