Mar 6, 2025 · Big Data

Real-Time Anti-Fraud Streaming System Based on Flink: Architecture, Challenges, and Optimizations

The article describes a Flink‑based real‑time anti‑fraud streaming system that combines a risk‑control platform, configurable YAML‑driven pipelines, and optimized state handling—using early event‑time triggers, micro‑batch caching, and coarse‑grained key reduction—to compute multi‑dimensional features, support rapid strategy updates, simulation filtering, and seamless output to ClickHouse, Hive, and Redis for both instant monitoring and offline analysis.

FlinkReal-time StreamingState Optimization

0 likes · 26 min read

Real-Time Anti-Fraud Streaming System Based on Flink: Architecture, Challenges, and Optimizations

Alibaba Cloud Developer

Feb 14, 2022 · Backend Development

How Kuaishou Boosted Flink SQL Performance with Window Extensions and State Optimizations

Kuaishou dramatically increased Flink SQL adoption, introduced Group Window Aggregate and Window TVF extensions, applied aggregation state reuse and mini‑batch techniques, and enhanced stability through data‑skew mitigation and aggregate‑state compatibility, outlining future plans for streaming and batch SQL improvements.

FlinkSQLState Optimization

0 likes · 19 min read

How Kuaishou Boosted Flink SQL Performance with Window Extensions and State Optimizations