一、故事背景 最近负责的业务由于三方配额不够，需要购买配额。问题来了，买多少配额合适？下图是目前的调用关系。由于是关于IOT的业务，其中老的实现是设备直接调用三方接口（安卓设...
发简信
IP属地：四川
-
记录一次三方配额事件及思考 -
Flink POJO类型ValueState演化原理剖析
一、起因 最近使用Flink(1.8.1)遇到一个问题，ValueState中数据结构的一个字段类型在开发的时候定义的是int类型，但是实际上应该是long类型。flink虽...
-
Flink应用高可用方案探索一、为什么要做高可用 由于依赖Flink应用A下游服务非常重要，对应用A所提供数据的实时性、可靠性要求比较高。所以对应用A进行了高可用改造，运行在两个独立的flink上，保障...
-
Hbase scanner逆向查询原理（上）客户端一、背景 一直听说hbase scanner的逆向查询比正向查询要慢很多，而且多消耗了很多资源。原因在哪里，并没有找到明确的答案。分为客户端和服务端两篇，正向和逆向的原理以及...
-
Flink中数量窗口增加等待时间
Flink窗口可以分为时间维度窗口和数据量窗口。其中时间维度窗口又可分为ProcessingTime和EventTime。一般情况下以时间作为窗口的应用场景更多一些，比如：统...