问题导读 1.为什么说Flink是高性能？ 2.什么是Flink状态计算? 3.Flink如何实现容错的？ 4.Flink为何要内存管理？ 5.Flink中 ...

pig2 2018-11-22 8 13932

问题导读 1.ssh安装需要注意什么问题？ 2.Flink集群配置文件是哪个？ 3.Flink常用配置参数的含义是什么？ 4.如何具体配置某 ...

pig2 2018-11-28 8 19113

问题导读 1.流处理和批处理分别入口是什么？ 2.对于本地和远程运行程序，都可以使用哪个函数？ 3.Flink数据源分为哪两类？ ...

pig2 2018-12-3 8 20657

问题导读 1.Flink中Map函数和FlatMap函数有什么区别? 2.如何生成KeyedStream？ 3.KeyedStream如何转换为DataStream ？ 4.min ...

pig2 2018-12-5 7 13690

问题导读 1.如何在window下安装Flink? 2.Flink本地安装启动命令与原先版本有什么区别? 3.window和Linux本地启动命令有什么区 ...

pig2 2018-11-26 7 16512

问题导读 1.项目的背景是什么？ 2.本文如何做技术选型的？ 3.中国移动项目的数据量有多少？ 4.中国移动项目集群多少台？ ...

hyj 2019-4-9 7 15051

问题导读 1.Flink有哪三种运行模式？ 2.Flink架构有几层? 3.Flink每层的作用是什么？ 4.JobGraph是什么？ 5.executiongraph ...

pig2 2018-11-15 6 24669

问题导读 1.Flink程序结是什么结构？ 2.Flink中source，sink分别是什么意思？ 2.Flink数据源有哪些？ 3.如何自定义Flink数 ...

pig2 2018-11-21 6 15782

问题导读 1.Apache Flink是什么？ 2.Flink在实现流处理和批处理时，与传统的一些方案有什么不同？ 3.Apache Flink流处理有哪 ...

xuanxufeng 2016-5-19 6 33724

问题导读 1.动态表有什么特点？ 2.流处理与批处理有什么相同之处？ 3.动态表和连续查询的关系？ 4.连续查询本文列举了什么例 ...

pig2 2019-1-17 5 12483

问题导读 1.Flink提交到运行程序涉及哪些进程？ 2.Flink slot是什么？ 3.Job客户端是不是Flink内部部分，它的作用是什么？ 4 ...

pig2 2018-11-19 5 25260

问题导读 1.Flink表的类型有哪几种？ 2.API与SQL客户端分别什么方式指定连接器？ 3.Scala和Java如何创建连接器？ 4.YAML配 ...

pig2 2019-2-18 4 21146

问题导读 1.为什么flink实时性好？ 2.flink通过什么机制保证数据既不重复，也不丢失？ 3.flink采用什么机制通信？ 4.flink ...

pig2 2018-10-8 4 26083

问题导读 1.Flink有哪两个关系API？ 2.Table API有那两种语言？ 3.Table API和SQL接口彼此集成的好处是什么？ 4.DataStrea ...

pig2 2019-1-9 4 9505

本帖最后由 sstutu 于 2018-10-24 15:33 编辑 问题导读 1.布衣格电信为何使用Flink？ 2.Flink每天处理多少事件？ 3.Flink集 ...

sstutu 2018-10-24 4 20901

问题导读 1.什么是广播状态模式？？ 2.什么是广播状态？ 3.使用广播状态时要注意哪4个重要事项？ 关注最新经典文章， ...

pig2 2018-11-12 4 10252

问题导读 1.DataStream和DataSet转换为Table有几种方式？ 2.如何将DataStream和DataSet注册为表？ 3.如何转换DataStream 或 ...

pig2 2019-1-14 4 8156

问题导读 1.如何实现Flink流分区？ 2.对于数据倾斜，该使用什么函数实现数据均衡？ 3.Rescaling与rebalance有什么区别？ ...

pig2 2018-12-17 3 13249

问题导读 1.窗口是什么时候开始创建的？ 2.窗口删除是什么时候？ 3.如何延迟窗口删除？ 4.Keyed和Non-Keyed Windows有什么 ...

pig2 2018-12-12 3 14087

问题导读 1.Atlas中实体具体指什么？ 2.如何为Flink创建Atlas实体类型定义？ 3.如何验证元数据收集？ 在Cloudera Stre ...

pig2 2021-3-22 3 6327

问题导读 1.Flink中可以使用Hadoop哪些内容？ 2.Hadoop InputFormat在Flink中视为什么？ 3.FlatMapFunction与Hadoop哪一 ...

pig2 2019-1-3 3 17498

问题导读 1.独立模式有哪些条件？ 2.循环模式模式该如何停止？ 3.subtype的作用是什么？ 上一篇： Flink难点：彻底明 ...

pig2 2019-6-11 3 14358

问题导读 1.集群搭建本文都说了哪些因素？ 2.什么情况下需要考虑网络容量？ 3.什么情况需要考虑磁盘宽带？ 4.除了6个因素 ...

pig2 2018-10-18 3 10836

问题导读 1.Spark 1.4有哪些特点？ 2.Flink 0.9有哪些特点？ 3.Spark与Flink分析对比是什么？ Spark是一 ...

丫丫 2015-7-26 3 23830

问题导读：1.怎样优化Logical Plan？2.怎样优化Stream Graph？3.TimeWindow，EventTime，ProcessTime 和 Watermark四者之间的 ...

fc013 2019-3-16 3 20154

本帖最后由 pig2 于 2018-10-29 15:49 编辑 问题导读 1.什么是State Backends？ 2.State Backends有什么作用？ 3.State Bac ...

pig2 2018-10-29 3 26870

问题导读 1.Flink有哪些内置连接器？ 2.Flink二进制发布包中是否直接可以使用连接器？ 3.如何才能添加连接器？ 4.连接器使 ...

pig2 2018-12-19 3 7325

问题导读 1.为何产生window窗口计算？ 2.你认为什么情况下使用Window Apply？ 3.Window Fold可以用来做什么？ 4.window 流 ...

pig2 2018-12-10 3 9766

问题导读 1.事件时间、处理时间、提取时间的顺序是什么？ 2.事件时间为何需要水印？ 3.处理时间是否提取的当前系统的时间？ ...

pig2 2018-12-13 3 16992

问题导读： 1.怎样保证版本演进的过程中实现向后兼容？2.新连接器有哪些优势？3.新连接器怎样实现的？ 最新经典文章， ...

fc013 2018-10-20 3 7030