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

pig2 2018-11-15 6 24692

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

pig2 2019-2-18 4 21155

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

pig2 2018-12-3 8 20698

问题导读 1.本地执行分为那两种？ 2.本地执行在程序方面有什么区别？ 3.集群执行，如何连接master？ 4.本地执行和集群执行 ...

pig2 2019-1-7 1 19711

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

pig2 2018-11-28 8 19126

问题导读 1.Flink表格式都支持哪些格式？ 2.Flink表格式都改如何定义和使用？ 3.Flink提供的额外哪些TableSource和TableSinks ...

pig2 2019-2-21 1 18975

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

pig2 2019-1-3 3 17527

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

pig2 2018-12-13 3 17012

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

pig2 2018-11-26 7 16545

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

pig2 2018-11-21 6 15788

问题导读 1.对于事件延迟，cep是如何处理的? 2.对于cep编程，本文举了一个什么例子？ 3.从较旧的Flink版本迁移有哪些需要 ...

pig2 2019-6-17 1 15082

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

pig2 2019-6-11 3 14367

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

pig2 2018-12-12 3 14121

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

pig2 2018-11-22 8 13953

问题导读 1.Flink内置哪些文件系统？ 2.Flink都支持哪些Hadoop版本？ 3.Flink对Avro的支持，需要哪些工作？ 上一篇 彻 ...

pig2 2019-1-2 1 13888

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

pig2 2018-12-5 7 13701

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

pig2 2018-12-17 3 13289

问题导读 1.Flink CEP解决什么问题？ 2.如何使用Flink CEP 3.CEP有哪些模式？ 4.CEP量词的作用是什么？ 5.本文讲了哪些量 ...

pig2 2019-6-3 2 13096

问题导读 1.DataSet与 Datastream Transformations 都有哪些API？ 2.DataSet MapPartition的作用是什么？ 3.ReduceGroup与Red ...

pig2 2018-12-24 2 12963

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

pig2 2019-1-17 5 12497

问题导读 1.组合模式需要哪些函数？ 2.事件之间的关系有哪三种？ 3.循环模式如何表示？ 4.循环模式中默认是哪个模式？ ...

pig2 2019-6-12 2 12200

问题导读 1.对于接受事件该如何实现过滤？ 2.CEP都有哪些条件？ 3.迭代条件和简单条件有什么区别？ 4.如何组合条件？ ...

pig2 2019-6-10 2 12179

本帖最后由 levycui 于 2020-7-22 11:18 编辑 问题导读： 1、如何配置 JobManager 内存？ 2、如何配置 JVM 堆内存？ 3、Fli ...

levycui 2020-7-22 0 11845

问题导读 1.Flink如何获取各种不同格式的文件，转换为dataset？ 2.Flink sources有哪些类型？ 3.Flink是否可以读取压缩文件 ...

pig2 2018-12-26 2 10811

问题导读 1.匹配跳过策略的作用是什么？ 2.匹配跳过策略有哪四种？ 3.匹配跳过策略代码如何实现？ 上一篇 Flink难点： ...

pig2 2019-6-17 2 10105

问题导读 1.PatternProcessFunction是哪个版本引入的？ 2.对于模式检测中超时部分处理使用什么接口？ 3.如何创建PatternStr ...

pig2 2019-6-17 2 9874

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

pig2 2018-12-10 3 9778

本帖最后由 pig2 于 2019-1-21 11:22 编辑 问题导读 1.Table和SQL API如何定义时间属性？ 2.如何将时间属性嵌入到Table和SQL ...

pig2 2019-1-21 1 9657

问题导读 1.Flink sql程序结构包含哪些内容？ 2.TableEnvironment的作用是什么？ 3.如何创建TableEnvironment？ 4.如何注 ...

pig2 2019-1-10 2 9602