华为云首页用户手册

MAPREDUCE服务 MRS-Flink常见问题:缓冲区超时设置

MAPREDUCE服务 MRS-Flink常见问题:缓冲区超时设置

时间：2024-10-16 17:58:34

MAPREDUCE服务 MRS 使用Flink

缓冲区超时设置

由于task在执行过程中存在数据通过网络进行交换，数据在不同服务器之间传递的缓冲区超时时间可以通过setBufferTimeout进行设置。
当设置“setBufferTimeout(-1)”，会等待缓冲区满之后才会刷新，使其达到最大吞吐量；当设置“setBufferTimeout(0)”时，可以最小化延迟，数据一旦接收到就会刷新；当设置“setBufferTimeout”大于0时，缓冲区会在该时间之后超时，然后进行缓冲区的刷新。
示例如下：
```
env.setBufferTimeout(timeoutMillis);

env.generateSequence(1,10).map(new MyMapper()).setBufferTimeout(timeoutMillis);
```

上一篇：MAPREDUCE服务 MRS-配置HetuEngine智能物化视图能力:HetuEngine智能物化视图概述

下一篇：MAPREDUCE服务 MRS-Hive表的HDFS目录被误删，但是元数据仍然存在，导致执行任务报错:回答

华为云11.11 2核1G 2M 云服务器

29元/年

立即注册领万元上云礼券

抽奖赢11111元免单

续费同价 L实例 2核2G 4M

98元/年

热门域名 1元随心购

1元/年

MAPREDUCE服务 MRS-Flink常见问题:缓冲区超时设置

意见反馈

0/200

提交成功！非常感谢您的反馈，我们会继续努力做到更好反馈提交失败！请稍后重试！

推荐文章

解决方案
相关专题