State Cache for Flink

A while back I participated in a project that resulted in a state cache for Apache Flink. The project can be found in the original GitHub repo (King) or in my fork in GitHub. The implemented cache boost Flink performance in a certain specific case – using RocksDB state backend (not a strict requirement though) and when the state (per key) is very large (e.g. kilobytes). Have a look at the GitHub repo for more details.

Leave a comment