一、Flink是什么
Apache Flink是开源的分布式流处理引擎，以毫秒级延迟处理实时数据流。Flink支持有状态的流计算，事件时间和水印机制保证数据准确性。统一批流处理让开发和运维更简单，广泛应用于实时数仓、实时风控和实时监控等场景。
一）核心架构
Flink采用主从架构，JobManager负责任务调度和状态管理，TaskManager执行计算任务。Checkpoint机制实现故障恢复，保证精确一次语义。状态后端存储算子状态，支持内存、文件系统和RocksDB。背压机制自动调节数据流速，防止系统过载。
二、Flink核心特性
事件时间处理应对乱序数据，窗口计算支持滚动、滑动和会话窗口。Watermark处理延迟数据，侧输出流收集迟到数据。Flink的DataStream和Table API满足不同开发需求，SQL让实时计算更易上手。连接器生态丰富，对接Kafka、MySQL、Elasticsearch等系统。
二）典型应用场景
实时数仓用Flink处理ODS到DWD的数据流转，实时指标计算支撑业务决策。实时风控基于事件流检测异常行为，毫秒级响应拦截风险。实时监控和告警处理日志和指标数据。实时推荐根据用户行为流更新推荐结果。
三、Flink开发与运维
开发Flink作业关注并行度设置和状态管理，合理配置资源避免浪费。提交方式支持YARN、Kubernetes和Standalone，容器化部署成为主流。监控指标包括吞吐量、延迟和checkpoint状态，调优结合业务特点。Flink版本迭代快，关注社区动态。
Flink让实时计算成为企业标配能力，掌握流处理架构和核心特性，构建高可靠实时数据系统。