Flink 在流式数据处理方面的能力非常强大，尤其值得一提的是它对带状态的流计算作业的支持度。它支持 Operator 和 Keyed 两类状态存储结构，其中后者因为用量大、用法多样，Flink 在这方面做了很多的支持：提供了纯粹基于堆...

流计算 Oceanus 的云 API 已经启用 CAM 服务级鉴权。默认情况下，所有主账号（也成为主用户）均有 QcloudOceanusFullAccess 策略，可以不用任何设置，正常使用流计算服务。...

对于需要保存超大状态（远超于内存容量）的流计算场景来说，目前 RocksDB [1] 是 Flink 平台上官方实现的唯一选择。业界也有使用 Redis 等其他服务作为状态后端的方案，但终究不够成熟，且已被社区否决 [2]....

Flink 提供了从 Tuple0 ~ Tuple25 的 Tuple 类供用户选择，顾名思义，每个 Tuple 对象分别可以存储 0 个 ~ 25 个任意类型的字段，例如图 1 展示了 Tuple2 的类定义。由于腾讯云 Oceanus 流计算的客户业务场景较为复杂，需要...

Flink 社区的 Spillable Backend 特性，社区经过了大半年的开发，目前已经放出了预览版可供体验。

在前文中，我们介绍了 Spillable Backend 及其 HeapStatusMonitor 的工作原理和不足。今天我们来看一下 Spillable Backend 的另一个核心组件：SpillAndLoadManager。如果说 HeapStatusMonitor 是测量系统负载的信号灯，那...

近期我们遇到了一位客户提出的问题：MySQL 建表时，数据库表定义的字符集是 latin1，里面的数据是以 GBK 编码的方式写入的。当 Flink 的 JDBC Connector 在读取此维表时，输出数据的中文出现了乱码现象，如下图：...

近期接到客户反馈，某地域的作业不定期的出现 JobManager 崩溃重启的问题。具体现象如下：

近期我们发现 Kubernetes 环境下的 Flink 集群有个奇怪的现象：在算子并行度较大（例如超过 50）时，Flink 的 TaskManager 注册异常缓慢（具体表现为 TaskManager 容器注册后过段时间就超时退出了，随后反复循环，导致作业迟迟分配...

流计算作业通常运行时间长，数据吞吐量大，且对时延较为敏感。但实际运行中，Flink 作业可能因为各种原因出现吞吐量抖动、延迟高、快照失败等突发情况，甚至发生崩溃和重启，影响输出数据的质量，甚至会导致线上业务中断，造成报表...