我得到错误“由以下原因引起：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，如何设置呢。
1条答案
按热度按时间4nkexdtk1#
执行时
DataSet你需要打电话的工作ExecutionEnvironment.createLocalEnvironment(Configuration configuration)为了传递一种习俗Configuration.执行时
DataStream你需要打电话的工作StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)为了传递一种习俗Configuration.