事件起因: 我司正在做tidb的调研, 需要使用tispark写数据, 核心代码如下: 上述代码实在RDD的foreachPartition 里面调用, 跑着跑着就报错误了,...

事件起因: 我司正在做tidb的调研, 需要使用tispark写数据, 核心代码如下: 上述代码实在RDD的foreachPartition 里面调用, 跑着跑着就报错误了,...
风幕了解下
一些好的设计 (一)1. 旋转门 问题: 不停地有客户进出, 开门后不知随手关门, 外面的噪音, 灰尘全都涌了进来 需求: 能不能想办法尽快做一种门, 它可以一直开着, 又一直关着 指标: 以...
CEP和状态机 状态机的表示和如何作用在流上 Flink中CEP的一般代码结构如下: 从上面可以看出入口是 一个一般的DataStream 然后进过一个Pattern, 得到...
0. 一些问题 window中的数据保存在什么地方 一个window操作有几大组件 1. Evictor 是否对窗口中的数据进行计算由Trigger来决定, Evictor ...