2021年Flink Forward Asia峰會嘉賓演講PPT合集（共79套打包）

1、王林紅易車數據平臺負責人FlinkFlink在易車落地應用與實踐在易車落地應用與實踐平臺現狀平臺現狀應用場景應用場景平臺建設平臺建設流批一體流批一體未來規劃未來規劃#1#2#3#4#5#1#1平臺現狀平臺現狀實時計算平臺發展歷程20182019202020211、storm、spark編碼開發2、低監控、無平臺3、開發效率低早期階段1、Flink 1.7落地使用2、SQL開發模式3、支持日志實時。

2、中原銀行實時風控體系建設實踐陳玉強中原銀行數據銀行部Construction practice of real-time risk control system of Zhongyuan bank中原銀行業務發展概況蟬聯六年金融時報“年度十佳城市商業銀行”，相繼榮獲“鐵馬十佳銀行”、“最佳上市公司”、“年度卓越城商行”等稱號2021年銀行家全球1000大銀行排185名2021年財富中國500強，。

3、吳江/蔚來大數據開發&Olap平臺 Tech LeadFlink在蔚來的應用實時計算在蔚來的發展歷程#1#1實時計算平臺#2#2實時看板#3#3CDP#4#4實時數倉#5#5其他應用場景#6#6#1實時計算在蔚來的發展歷程實時計算在蔚來的發展歷程正在進行實時計算平臺2.02021-01實時計算平臺1.02019-09引入Flink命令行方式提交和管理2018-05Spark stream。

4、張迎/實時計算平臺負責人作業幫基于作業幫基于FlinkFlink的實時計算平臺實踐的實時計算平臺實踐發展歷程發展歷程Flink SQL應用實踐平臺建設總結展望#1#1#2#2#3#3#4#4整體架構數據庫業務側日志KafkamysqlApp,web,后端業務側CanalFuxi實時離線實時計算Flink離線計算SparkStreaming/MRStarRocksDorisHologresESHi。

5、馮斐/王非凡 美團數據平臺工程師美團Flink大作業部署與狀態穩定性優化實踐相關背景#1大作業部署優化#2Checkpoint跨機房副本#3未來規劃#5目錄狀態穩定性相關優化#42#1相關背景3美團Flink應用場景數據管道數據分析事件處理-數據實時入倉-跨數據源實時同步-實時數倉-實時特征生產-安全風控-系統監控告警4機器數美團Flink計算規模15K50K 5.4億/秒 作業數5K高峰流量作。

6、劉桂海/架構師特來電云平臺智能運維應用實踐特來電云平臺智能運維應用實踐特來電云平臺簡介1234Flink在特來電云平臺智能運維的未來計劃特來電云平臺智能運維簡介Flink在特來電云平臺智能運維的應用場景#1#1特來電云平臺簡介特來電云平臺簡介要加強新型基礎設施建設（即新基建新基建），發展新一代信息網絡，拓展5G應用，建設充電樁充電樁，推廣新能源汽車，激發新消費需求、助力產業升級。-2020年政府。

7、張蛟/小米高級軟件工程師Apache FlinkApache Flink在小米的在小米的穩定性優化和實踐穩定性優化和實踐Stability optimization and practice of Apache Flink at Xiaomi發展現狀發展現狀和規模和規模穩定性優化穩定性優化及實踐及實踐運維優化運維優化及實踐及實踐未來規劃未來規劃與展望與展望#1#2#3#4#1#1發展現狀及規模發。

8、李勁松/阿里巴巴技術專家基于 Flink Dynamic Table 構建流批一體數倉業務痛點動態表流式數倉PLAN#2#3#4#5#1業務需求#1 1業務需求業務需求Streaming ETL搭建實時數倉搭建實時數倉Day ResultsWeek ResultsMonth ResultsJoinAggregationsODSDWDADS BOSS:快快快！給我看到實時的數據！即席查詢與數據訂正。

9、劉迪珊美團基于流批一體構建增量數倉生產實踐The Production Practice of Building Incremental Data Warehouse based on Unified Architecture at Meituan項目目標核心設計與實現計算能力優化未來展望#1#2#3#4#1項目目標數倉生產面臨的問題#1離線實時兩套計算邏輯，口徑難統一：離線實時數據生產，采用兩。

10、高赟（云騫）面向流批一體的面向流批一體的FlinkFlink RuntimeRuntime新進展新進展The New Features of the Runtime for Unified Batch and Stream Processing流批一體流批一體性能優化性能優化RemoteRemoteShuffleShuffle總結與展望總結與展望#1#2#3#4#5語義完善語義完善與增強與增強#。

11、鄒丹/劉洋字節跳動基礎架構工程師Powering HTAP at Powering HTAP at ByteDanceByteDance withwithApache Apache FlinkFlinkFlinkFlink OLAPOLAP OptimizerOptimizer ImprovementImprovementFlinkFlink OLAPOLAP RuntimeRuntime Im。

12、演講者：林東-阿里巴巴高級技術專家 Apache Kafka PMC高赟-阿里巴巴技術專家 Apache Flink Committer共同作者：張智鵬 阿里巴巴高級開發工程師為實時機器學習設計的算法接口與迭代引擎為實時機器學習設計的算法接口與迭代引擎流批一體的迭代引擎流批一體的迭代引擎FlinkFlink MLML 生態建設生態建設面向實時機器面向實時機器學習的學習的APIAPI#1#2#3#。

13、李明/字節跳動基礎架構工程師StateBackendStateBackend PerformancePerformanceImprovements with CacheImprovements with Cache相關背景相關背景Background優化思路優化思路Ideas難點難點&方案方案Difficulties&Solutions業務收益業務收益Benefits未來規劃未來。

14、孫夢瑤/美團開發工程師Flink 流式 Join 算子優化Optimizations on Flink Streaming Join OperatorsJoin 算子現有實現和問題#1Regular Join mini-batch 優化#2Interval Join 1 對 N 關聯優化#3Join 算子優化的落地與實踐#4#1Join 算子現有實現和問題為什么需要 Join 算子 事物之間存在。

15、楊旭/阿里巴巴資深算法專家AlinkAlink的新進展及典型示例的新進展及典型示例New progress and typical examples of Alink內容提綱概述新算法-深度學習組件-流式特征工程-時序算法組件新功能-推理組件加速-模型流-Web UIAlink教程（Java版，Python版）未來展望What is Alink Alink是基于Flink的機器學習算法平臺Ali。

16、姜鑫&蔣曉峰基于基于AIFlowAIFlow的機器學習工作流最佳實踐的機器學習工作流最佳實踐實時機器學習實時機器學習AIFlowAIFlow 介紹介紹最佳實踐最佳實踐#2#3RoadmapRoadmap#4#1#1#1實時機器學習實時機器學習離線機器學習工作流離線機器學習工作流Feature StoreApplicationQueueArchived DataBatchFeature G。

17、Where will BigData technology go?under the trend of HTAPDongxu Huang,PingCAPAbout meAbout me Dongxu(Ed)Huang CTO,PingCAP Database/Distributed System Big fan of OSS,TiDB/TiKV/Codis When we talk about 。

18、章劍鋒阿里云EMR數據開發負責人大數據三劍合一：大數據三劍合一：FlinkFlink+ZeppelinZeppelin+AirflowAirflowFlinkFlink onon ZeppelinZeppelin 現狀現狀#1#1Airflow Airflow 簡介簡介#2#2Zeppelin+Zeppelin+Airflow Airflow#3#3DemoDemo#4#4#1#1FlinkFl。

19、周煜敏戴爾科技集團高級軟件工程師Pravega Flink connector Table API 進階功能探秘Deep dive into the extended Table API usage of Pravega Flink connector動態表與流表二相性動態表與流表二相性#1#1Debezium支持支持#2#2Pravega Schema registry#3#3Catalog支。

20、螞蟻金服實時計算引擎建設閔文俊/螞蟻集團技術專家云化實踐SQL算子與運行時優化未來展望#1#2#3#1云化實踐云化實踐 Native Kubernetes 部署 結合螞蟻云原生組件，提供云原生的體驗 通過operator組件，進行作業管理以及和內部組件交互輕量化運維145632更好的隔離性資源使用效率無盤化日志采集nydus鏡像加速kata安全容器資源動態伸縮框架Vpa In-place upd。

21、趙榮生網易云音樂實時場景應用及優化實踐簡介分區流表動態分發其他工作未來規劃#1#2#3#4#5#1簡介集群規模3000/1000集群節點數任務數流量40000/1200300PB/20GBps業務場景大盤數倉推薦算法監控ABBI穩定性監控指標不完善Kafka流量壓力增大HDFS小文件問題空跑任務浪費資源遇到問題效率大量重復無用讀取并行度受限topic分區數TM IO overhead高數據傾斜計。

22、張楊/資深開發工程師FlinkFlink 在在B B站的多元化探索與實踐站的多元化探索與實踐平臺建設平臺建設增量化增量化AIAI On FlinkOn Flink#1#2#3#1#1平臺建設平臺建設平臺建設基礎功能完善基礎功能完善lkafkakafka動態動態sinksinkl提交器優化提交器優化新任務構建模式新任務構建模式l算子化算子化智能診斷智能診斷l錯誤分析錯誤分析l自動調優自動調優top。

23、何軍/小紅書Native Native FlinkFlink on on KubernetesKubernetes在小紅書的實踐在小紅書的實踐多云部署架構多云部署架構#1支持業務場景支持業務場景#2HELMHELM集群管理集群管理#3Native Native FlinkFlink on K8son K8s實踐實踐#4流批一體作業管控平臺流批一體作業管控平臺#5未來展望未來展望#6#1#1多云部。

24、付海濤/資深技術專家FlinkFlink on K8s on K8s 在京東的持續優化實踐在京東的持續優化實踐The Practice and Optimization of Flink on K8s in JD 基本介紹基本介紹The IntroductionThe Introduction生產實踐生產實踐The Practice The Practice#1#2#3#4優化改進優化改進The。

25、林小鉑 網易游戲資深開發工程師網易游戲 Flink SQL 平臺化實踐Flink SQL Platform Construction Practice in Netease Games網易游戲 Flink SQL 發展歷程#1基于模板 jar 的 StreamflySQL#2基于 SQL Gateway 的 StreamflySQL v2#3未來工作#4#1網易游戲 Flink SQL 發展歷程。

26、網易 馬進ArcticArctic：基于：基于Flink+icebergFlink+iceberg 的湖倉一體的湖倉一體Arctic:Using flink and iceberg to build netease lakehouse背景與目標背景與目標#1Background and goalsArctic Arctic 特性特性#2Arctic featuresArctic Arctic 架。

27、李延加/Gary LiSoftware Engineer ByteDanceApache Hudi PMC MemberBuildingBuilding TheThe RealReal-timetime DatalakeDatalakeatat ByteDanceByteDanceByteDanceByteDance DataData IntegrationIntegration#1WhyWhy。

28、袁尤軍SmartNews 基于 Flink 的實時數倉建設Flink 在 SmartNews：歷史與現狀#1實時數倉的發展背景和策略#2一個具體例子#3未來的規劃和挑戰#4Q&A#5#1Flink 在 SmartNews:歷史與現狀關于 SmartNews201220142019東京紐約/舊金山/帕托上海/北京Flink 在 SmartNews 的發展歷史2020Q2實時平臺立項Flin。

29、汪李之/大數據工程師Flink 在訊飛AI營銷業務實時數倉實踐業務簡介數倉演進場景實踐未來展望#1#2#3#4#1業務簡介業務流程流量交易平臺流量方廣告主流量方在交易平臺售賣流量廣告主在交易平臺購買流量，投放廣告請求曝光點擊投放平臺業務場景業務日志業務分析用戶日志到分析的過程數據呈現的時效性數據倉庫實時數據倉庫#2數倉演進數倉框架業務日志流(Log Stream)OLTP數據庫第三方文檔數據OD。

30、康琪/十薈團大數據工程師,Apache Flink Contributor 十薈團基于Flink SQL與Zeppelin構建實時數倉的實踐Flink SQL&Zeppelin-Based Practices of Real-Time Data Warehouse at NiceTuan實時數倉建設Construction of Real-Time Data Warehouse#1數倉平。

31、袁一中國工商銀行大數據平臺負責人工商銀行實時大數據平臺建設歷程及展望#1#1#2#2#3#3展望工行實時大數據平臺建設思路工行實時大數據平臺建設歷程#1#1工行實時大數據平臺建設歷程數據集市數據倉庫大數據服務云大數據服務云生態圈數據中臺Hadoop分布式數據庫大內存Hadoop分布式數據庫大內存（2002-2007年）（2008-2013年）（2014-2016年）（2017-2019年）（20。

32、師銳字節計算基礎架構負責人實時計算在字節跳動的發展與展望#1#1#2#2#3#3發展概覽#4#4歷程回顧重點工作展望總結#1#1發 展 概 覽國 內 業 務海 外 業 務字 節 跳 動 旗 下 產 品實 時 信 息 流 推 薦規 模 與 挑 戰實時推薦請求海量存儲空間全球 MAU國家與地區運營1919億億150150個個EBsEBs百萬百萬 QPSQPS實時計算在字節跳動的主要應用場景#1#1#。

33、郭育波/高級技術專家FlinkFlink在眾安保險金融業務應用在眾安保險金融業務應用整體概況整體概況智能營銷應用智能營銷應用實時特征應用實時特征應用后期規劃后期規劃#1#2#3#5反欺詐應用應用#4#1#1整體概況整體概況實時計算架構實時計算架構ODSRaw_TableDWD/DIMDWSkafkaFlink SQL/Flink Stream API業務數據庫用戶行為埋點應用消息事件kafkaV。

34、夏暢斗魚實時計算負責人Apache Flink在斗魚的應用與實踐背景介紹實時平臺建設實時數倉探索未來發展與展望#1#2#3#4#1背景介紹實時計算發展之路2018201820192020spark streaming jarSparkstrom taskStormflink1.9、flink1.10、flink1.11、flink1.12玄武計算flink jarFlink業務場景廣告大屏推薦風。

35、劉成龍/實時數倉項目負責人FlinkFlink流處理在中信建投證券的實踐與應用流處理在中信建投證券的實踐與應用蔡躍/金融資訊數據研發工程師中信建投證券介紹2005年成立成立2016年香港聯交所上市2018年上交所主板上市上市上市投資銀行業務連續8年保持行業前3名托管證券市值4.31萬億元，位居行業第2名主要經營指標目前均位居行業前10名發展發展中信建投證券中信建投證券 FlinkFlink 架構。

36、劉建剛/技術專家Flink引擎在快手的深度優化與生產實踐快手Flink的歷史及現狀#1容錯能力提升#2Flink引擎控制與實踐#3快手批處理實踐#4未來規劃#5目錄#1快手Flink的歷史及現狀發展歷程平臺化建設典型業務實時化易用性、穩定性、可維護性流批一體、完善生態Flinkstream&batchKafkaRocketMQClickhouseRedisHbaseMySQLHiveHu。

37、胡家煊/字節跳動推薦架構數據研發工程師流批一體在字節跳動特征平臺的實踐流批一體在字節跳動特征平臺的實踐Practice of Flink Stream-Batch Unification in ByteDance recommendation system背景介紹背景介紹特征平臺架構特征平臺架構流批一體實踐與探索流批一體實踐與探索#1#1#2#2#3#3未來規劃未來規劃#4 4#1#1業務背景業。

38、毛言粲/新加坡國立大學SANE-LabTrisk：以Task為中心的流處理動態配置的控制平臺背景：流作業動態調控挑戰：兼顧普適、高效和易用設計：以Task為中心的系統設計實現：基于Flink的Barrier機制評估：Trisk與已有系統的性能對比#1#2#3#4#5#1背景：流作業動態調控流處理的大規模運用機器學習數據分析實時交易流式數據流作業（Stream Job）流處理的大規模運用 長期執行。

39、方勇/字節跳動基礎架構工程師Improvements of Job Scheduler and Improvements of Job Scheduler and Query Execution on Flink OLAPQuery Execution on Flink OLAP背景背景BackgroundBackground問題和分析問題和分析Problems Problems&A&a。

40、李志麗/奇虎360A C/C+online feature serving solution for Flink使用Flink/Alink的批流一體特征工程#1在C/C+Online場景下的一些局限#2一種可行的解決方案：Clink#3Clink與Flink共同實現在線學習#4Clink在360的應用#5Clink開源#6使用Flink/Alink的批流一體特征工程機器學習和在線學習（Onlin。

41、陶然/阿里巴巴高級開發工程師、Apache Spark&Flink Contributor周躍躍/螞蟻集團 OceanBase 架構師螞蟻實時計算 Flink on OceanBase#1#1螞蟻實時計算生產實踐螞蟻實時計算生產實踐#2 2#3#3螞蟻螞蟻 FlinkFlink OnOn OceanBaseOceanBaseOceanBaseOceanBase 社區版技術架構及核心特性社。

42、劉巖/Cloudera Solution EngApacheApache AtlasAtlas MeetsMeets ApacheApache FlinkFlink為什么 Flink 需要對接血緣系統#1#1什么是 Apache Atlas#2#2對接技術實現及未來#3#3目錄為什么 Flink 需要對接血緣系統#1#1Flink的三大應用場景Data PipelineAnalyticEvent。

43、謝磊 中國移動云能力中心Apache Flink 在移動云實時計算的實踐中移（蘇州）軟件技術有限公司（中國移動云能力中心）是中國移動通信有限公司的全資子公司。公司定位為中國移動云設施構建者、云服務提供者、云生態匯聚者。公司以移動云運營為中心，產品和服務在電信、政務、金融、制造、交通、醫療等行業得到廣泛應用。N+31+X200+2500+100萬+屬地化資源池支撐產品應用客戶實時計算平臺介紹#1中。

44、鄒云鶴/BIGO Staff EngineerBIGOBIGO使用使用FlinkFlink做做OlapOlap分析及實時數倉的分析及實時數倉的實踐及優化實踐及優化背景背景落地實踐落地實踐特色特色&改進改進業務場景業務場景未來規劃未來規劃#1#2#3#4#5#1#1BIGO OLAPBIGO OLAP分析平臺分析平臺&實時數倉的業務背景實時數倉的業務背景主要業務為全球用戶提供直播服。

45、胡爭 Apache Iceberg&HBase PMCApache Apache FlinkFlink 集成集成 Apache Iceberg Apache Iceberg 最佳實踐最佳實踐HiveHive表面臨的挑戰表面臨的挑戰IcebergIceberg的解決方案的解決方案FlinkFlink和和IcebergIceberg最佳實踐最佳實踐現狀及規劃現狀及規劃#1#2#3#4#1#1。

46、龍逸塵/騰訊大數據高級工程師騰訊云原生實時數倉建設實踐騰訊云原生實時數倉建設實踐The Practice of Constructing Cloud Native Real-time Data Warehouse in Tencent實時數倉實時數倉挑戰挑戰#1實時數倉實時數倉演進演進#2實時數倉實時數倉實踐實踐#3實時數倉實時數倉展望展望#4目錄目錄#1#1實時數倉挑戰實時數倉挑戰實時數倉應用。

47、李天朔/快手實時數據技術專家快手實時數倉保障體系研發實踐快手實時數倉保障體系研發實踐業務特點業務特點實時數倉保障痛點實時數倉保障痛點實時數倉保障實時數倉保障體系架構體系架構春節活動實時春節活動實時保障實踐保障實踐未來規劃未來規劃#1#2#3#4#1#1業務特點及實時數倉保障痛點業務特點及實時數倉保障痛點快手實時應用場景業務特點？保障訴求保障訴求保障訴求保障訴求嚴格資源管控極致壓榨性能鏈路分級機制。

48、Flink Next:Beyond Stream Processing王峰（莫問）阿里巴巴開源大數據平臺負責人2021:Apache Flink 社區持續繁榮本數據來源 Apache 基金會 2021 財年報告：https:/www.apache.org/foundation/docs/FY2021AnnualReport.pdfApache Flink 年度發布總結Flink 在2021年發布。