Popular GitHub Repositories for Flink

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

BigDL: Distributed TensorFlow, Keras and PyTorch on Apache Spark/Flink & Ray

GeaFlow: A Streaming Graph Computing Engine.

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

A Scala feature transformation library for data science and machine learning

FeatHub - A stream-batch unified feature store for real-time machine learning

Machine learning library of Apache Flink

??DatalinkX异构数据源之间的数据同步系统，支持海量数据的增量或全量同步，同时支持HTTP、Oracle、MySQL、ES等数据源之间的数据流转，支持中间transform算子如SQL算子、大模型算子，底层依赖Flink、Seatunnel引擎，提供流转任务管理、任务级联配置、任务日志采集等功能??

Dataset Batch(offline) Reinforcement Learning for recommender system

Examples for Deep Learning/Feature Store/Spark/Flink/Hive/Kafka jobs and Jupyter notebooks on Hops

Recommender system based on Flink and Reinforcement Learning

flink-jpmml is a fresh-made library for dynamic real time machine learning predictions built on top of PMML standard models and Apache Flink streaming engine

Flink Agents is an Agentic AI framework based on Apache Flink

? A scalable, production-ready data pipeline for real-time streaming & batch processing, integrating Kafka, Spark, Airflow, AWS, Kubernetes, and MLflow. Supports end-to-end data ingestion, transformation, storage, monitoring, and AI/ML serving with CI/CD automation using Terraform & GitHub Actions.

在原DatalinkX项目基础上进行了扩展，Flink+大模型（DeepSeek）智能数据中台;

A general Inference API based on two of the most popular Big Data processing engines: Apache Spark and Apache Flink

在原作者（SplitfireUptown）datablinkx项目基础上进行了扩展，1.添加用户管理模块datalinkx-security，2.添加DeepSeek大模型模块datalinkx-deepseek

Local environment for running Factor House products (Kpow and Flex) along with supporting infrastructure using Docker Compose

Streaming machine learning using PyTorch, Flink, and ONNX

Generic Model Serving Implementation leveraging Flink