240 发简信
IP属地:福建
  • Spark误用client导致`unable to create new native thread`

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

  • 风幕了解下

    一些好的设计 (一)

    1. 旋转门 问题: 不停地有客户进出, 开门后不知随手关门, 外面的噪音, 灰尘全都涌了进来 需求: 能不能想办法尽快做一种门, 它可以一直开着, 又一直关着 指标: 以...

  • Flink对于CEP的大概实现

    CEP和状态机 状态机的表示和如何作用在流上 Flink中CEP的一般代码结构如下: 从上面可以看出入口是 一个一般的DataStream 然后进过一个Pattern, 得到...

  • Flink对于Window的实现

    0. 一些问题 window中的数据保存在什么地方 一个window操作有几大组件 1. Evictor 是否对窗口中的数据进行计算由Trigger来决定, Evictor ...