【翻译】Flink Table Api & SQL — 性能调优 — 流式聚合
本文翻译自官网：Streaming Aggregation https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/tuning/streaming_aggregation_optimization.html ...
原文：Flink 流式聚合性能调优指南
原文：Flink 流式聚合性能调优指南 SQL 是数据分析中使用最广泛的语言。Flink Table API 和 SQL 使用户能够以更少的时间和精力定义高效的流分析应用程序。此外，Flink Table API 和 SQL 是高效优化过的，它集成了许多查询优化和算子优化。但并不是所有的优化都是默认开启的，因此对于某些工作负载，可以通过打开某些选项来提高性能。 这里将介绍一些实用的优化选项以及流 ...
2020-05-27 14:48 1 919 推荐指数：
相关推荐
Flink性能调优(一)
1 配置内存 如果频繁出现Full GC，需要优化GC 在客户端的"conf/flink-conf.yaml"配置文件中，在“env.java.opts”配置项中添加参数： -Xloggc:<LOG_DIR>/gc.log -XX:+PrintGCDetails -XX ...
Mycat性能调优指南
本篇内容来自于网络 JVM调优： 内存占用分两部分:java堆内存+直接内存映射（DirectBuffer占用），建议堆内存 适度大小，直接映射内存尽可能大，两种一起占据操作系统的1/2-2/3的内存。 下面以服务器16G内存为例，Mycat堆内存4G，直接内存映射6G，JVM ...
性能调优8：分组聚合 - group by
聚合实际上对数据做分组统计，SQL Server使用两种操作符来实现聚合，流聚合（Stream Aggregation）和哈希聚合（Hash aggration）。流聚合是非阻塞性的，具有流的特性，流聚合操作符；边处理数据，边输出聚合的结果。而哈希聚合是阻塞性的，只要处理完所有的数据，才会输出聚合 ...
Docker中应用的性能调优指南（一）- 先谈谈容器化性能调优
前言 性能调优是一个老生常谈的话题，通常情况下，一个应用在上线之前会进行容量规划、压力测试并进行验证，而性能调优则是在容量规划与验证结果之间出现差异时会进行的必然手段。从某种角度来讲，性能调优是一个非常需要经验的领域，需要调优人员对应用的架构、调用的链路、使用的语言、操作系统的差异、内核的参数表 ...
Flink调优法则
Flink调优法则 一. 性能定位 口诀分析 1. 看背压 通常最后一个背压高的subTask的下游就是job的明显瓶颈之一 2. 看checkoint时长 checkpoint的时长在一定程度上可以影响job的整体吞吐 3. 查看关键指标 通过延迟与吞吐指标可以对任务的性能 ...
Flink 实时写入数据到 ElasticSearch 性能调优
Flink 实时写入数据到 ElasticSearch 性能调优 原创： 张刘毅 zhisheng zhisheng 微信号zhisheng_blog 功能介绍Flink 实时计算框架基础&进阶&实战&源码解析，死磕 ...
借助flink来对es的写入性能进行调优
转载：https://my.oschina.net/u/2828172/blog/443419 背景说明 线上业务反应使用 Flink 消费上游 kafka topic 里的轨迹数据出现 backpressure，数据积压严重。单次 bulk 的写入量为：3000/50mb/30s ...