RocksDBStateBackend 是 Flink 中用来存储大状态的 StateBackend。
Flink FsStateBackend 介绍
发表于
|
分类于
Apache Flink StateBackend
FsStateBackend 可能是大部分公司里最常用的一种 StateBackend 了。
Flink网络栈中反压机制的优化
发表于
|
分类于
Apache Flink
之前总是听到别人说 Flink 本身的反压机制有多么优秀,直到自己真正在应用中碰巧踩到坑,仔细研究后才发现,这个反压机制貌似并不完美。
SparkSQL写入Hive动态分区的优化
发表于
|
分类于
Apache Spark
实际业务中,我们通常会以时间作为分区来建立Hive表,然后在SparkSQL中以动态分区的形式插入,发现一个优化空间。