加一 (廖嘉逸)

Flink 和 HDFS 的交互

发表于 2019-10-21 | 分类于 Apache Flink

了解 Flink 和 HDFS 之间的交互有助于我们理清 HDFS 可能会给 Flink 带来的问题。

发表于 2019-09-22 | 分类于未分类技术文章

Kryo 可以通过各种方式序列化没有继承 Serializable 的 Java 类，但是当反序列化有些对象时，如不支持无参构造函数的对象，会出现这样的错误：

发表于 2019-09-09 | 分类于 Apache Flink

Apache Flink 在 Dispatcher、JobMaster、ResourceManager、TaskExecutor 几大组件之间采用 akka 进行通信。

发表于 2019-08-04 | 分类于 Apache Flink CEP

关于我之前写的 CEP 博客，可以点击这里。

发表于 2019-07-23 | 分类于 Database

在轻量级数据库中，我们不得不提到 RocksDB。这是 Database 系列的第二篇，由于工作原因，距离第一篇已经比较遥远，RocksDB 在我的周围经常可以听到，比如作为 Flink 的状态存储介质，TiDB 基于 RocksDB 做了 Google Spanner 的分布式实现等。

发表于 2019-07-11 | 分类于 Notes

这是我在极客时间买的第一个课程，在这里纯粹是当做笔记…

发表于 2019-06-20 | 分类于 Apache Flink

之前总是听到别人说 Flink 本身的反压机制有多么优秀，直到自己真正在应用中碰巧踩到坑，仔细研究后才发现，这个反压机制貌似并不完美。

发表于 2019-06-16 | 分类于未分类技术文章

Disruptor是2011年由LMAX提出的一个无锁消息队列，在短短45分钟的视频分享中，有很多的信息可以分享和深究。

发表于 2019-05-27 | 分类于 Notes

之前被推荐了极客时间的这个课程，想想也是蛮需要的，在这里记录一下自己对每节的总结和思考。

发表于 2019-05-13 | 分类于 Apache Flink

前两天看到Flink的dev邮件列表里有一个对StreamTask的重构，今天研读了一下，觉得Flink的开发者们在处理问题上，确实是有点大道至简的感觉。具体的Proposal地址点击这里。