张静- ApacheFlink流批一体的规划和在快手的进展

统一API：SQL & Table API、Relational DataStream、Physical DAG、Scheduler、DAG API、Unified Source API & Sink API & Operator API、Pluggable Shuffle API。
Pipeline Region Scheduling：以Pipelined边连接的Task集合作为基本调度单元，通过Pipeline Region Scheduler进行调度。
Adaptive Batch Scheduling：根据已结束的producer的数据量动态确定下游并发度，无需用户手动设置批作业的并发度，自动适应数据量变化。
Pluggable Shuffle API：支持Blocking Shuffle、External Shuffle Service、Remote Shuffle Service、Pipeline Shuffle，规划中支持Hybrid Shuffle。

架构：Remote Shuffle Manager、Shuffle Worker、Task Shuffle Master、JobManager。
进度：已对接内部RemoteShuffleService，从1.13版本迁移到1.15版本，适配AdaptiveBatch Scheduler，完成全链路功能验证和数据正确性验证。

架构：Speculative Scheduler、Slow Task Detector、BlackList Tracker、Slot Pool、Slot Manager。
Vertex：Source和Sink支持推测执行。
进度：核心调度层的设计和POC已完成，Source和Sink支持推测执行，从1.14版本迁移到1.15版本，适配Adaptive Batch Scheduler，完成全链路功能验证和数据正确性验证，计划贡献到社区1.16版本。

SQL语法：Flink规划支持Join Hints（1.16版本）、Sort by/Distributed by/Cluster by（1.16版本）、ANSI SQL Compatibility（已具备，持续优化）、HIVESQL Compatibility（已具备，规划中1.16版本）。
功能：Flink规划支持Implicit TypeConversion（1.16版本）、Complex hash key type（1.16版本）、Adaptive Query Execution（已具备）、Dynamically set parallelism（已具备）、Dynamically coalescing shuffle partition（规划中1.16版本）、Dynamically switching join strategies（规划中1.17版本）、Dynamically optimizing skew joins（规划中1.17+版本）。
其他：Flink规划支持Speculative Execution（1.16版本）、SQLGateway（1.16版本）、SparkThriftServer（规划中1.16版本）、OLAP（规划中1.16+版本）、Runtime Filter（规划中1.16版本）、Hybrid Shuffle（规划中1.16+版本）、Vectorized Execution（规划中，Photon仅在databricks runtime可用）。