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 集群和引擎,提高作业开发运维效率。