Security (distributed authentication framework, k8s operator automatic credential refresh), state management (state processor API, SQL state connector, RocksDB storage), Kubernetes operator health checks.

Health check framework, automatic credential refresh for long-running Flink applications on Kubernetes.

RocksDB fork optimised for Apache Flink's state backend. Bugfixes and release management.

Kafka connector v2 migration, consumer/producer caching, offset management redesign, distributed authentication framework, external SQL database JDBC auth integrations (Postgres, DB2, MariaDB, MS SQL, Oracle), history server.

Security and connector contributions.