Flink Forward Asia 2021 有奖问答专场汇总
Flink SQL 在快手的落地和扩展
张静｜快手实时计算团队技术专家，Apache Flink Committer
张芒｜快手实时计算团队技术专家
Flink State-Backend Improvements and Evolution in 2021
李钰｜阿里巴巴资深技术专家，ASF Member，Apache Flink & HBase PMC
唐云｜阿里巴巴技术专家，Apache Flink committer
Powering HTAP at ByteDance with Apache Flink
刘洋｜字节跳动基础架构工程师，Apache Flink Contributor
邹丹｜字节跳动基础架构工程师，Apache Flink Contributor
深入解析 Flink 细粒度资源管理
郭旸泽｜阿里巴巴高级开发工程师，Apache Flink Committer
Flink Join 算子优化
孙梦瑶｜美团资深开发工程师
Flink 新一代流计算和容错 - 阶段总结和展望
梅源｜阿里巴巴开源大数据架构师，Apache Flink 引擎架构师，Apache Flink Committer
Improvements of Job Scheduler and Query Execution on Flink OLAP
方勇｜字节跳动基础架构工程师
面向流批一体的 Flink Runtime 新进展
高赟｜阿里巴巴技术专家，Apache Flink Committer
Trisk：在 Flink 上实现以 task 为中心的流处理动态 reconfiguration 的 control plane
毛言粲｜新加坡国立大学
Flink Connector 社区新动向与 Hybrid Source 原理实践
任庆盛｜阿里巴巴开发工程师，Apache Flink Contributor
蒋晓峰｜阿里巴巴技术专家，Apache RocketMQ & Apache ShardingSphere & SOFAJRaft Committer，Apache Flink Contributor
基于 FFI 的 PyFlink 下一代 Python 运行时介绍
黄兴勃｜阿里巴巴高级开发工程师，Apache Flink Committer，PyFlink 核心贡献者
StateBackend Performance Improvements with Cache
李明｜字节跳动基础架构工程师，Apache Flink Contributor
为实时机器学习设计的算法接口与迭代引擎
林东｜阿里巴巴高级技术专家，Apache Kafka PMC Member
高赟｜阿里巴巴技术专家，Apache Flink Committer
写回答
面向流批一体的 Flink Runtime 新进展：高老师您好，有幸听过您两次关于Flink Runtime的分享，都提到Flink的流部分和批部分同时存在于同一作业中体现在作业中是Pipline shuffle和Blocking Shuffle。这类作业有具体应用场景吗？代码该如何编写这类型作业（批流同属于一个作业），source端是基于Hybrid Source吗。谢谢。
flink在进行流join过程中，如果两条流元素相差的时间gap过大，可能隔个好几天，元素一直保存在状态中会产生oom问题，这种问题是怎么解决的，放弃流join使用外部存储介质
大家好，状态存储（State Backend）和快照（checkpoint/savepoint）相关的问题在这里集合啦
Flink SQL 模块的功能上和性能上都做了很多扩展和实践: 张老师您好，对您提到的对 Flink SQL 模块的功能上和性能上都做了很多扩展和实践很感兴趣，目前我们也想要沉淀一些业务方需要的复杂常用的功能，包括状态存储和计算，作为封装好的SQL算子/函数去拓展Flink SQL功能。但似乎目前SQL的UDF不支持直接操作Flink内置状态存储？ 想咨询，大佬有无遇到此类场景，又是怎么解决实践的？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
