问题导读 1.Flink最大并行度如何设置？ 2.产生中Flink状态后端最好使用什么？ 3.配置 JobManager 的高可用性有什么好处？ ...

hyj 2020-2-20 0 4874

本帖最后由 levycui 于 2020-11-4 22:13 编辑 问题导读： 1、CDC是什么？ 2、Flink提供的 table format如何实现？ 3、如何 ...

levycui 2020-11-4 0 4805

本帖最后由 BGnv5 于 2019-8-17 15:51 编辑 问题导读： 1.为什么Kubernetes和Akka不能同时保证safety和liveness呢？ 2.计 ...

BGnv5 2019-8-17 1 4802

问题导读： 1、怎样使用Flink CDC实现全量读取 + 增量读取 Mysql 表数据？ 2、怎样使用Flink CDC实现切片划分、切分读取？ ...

fc013 2021-11-13 0 4771

问题导读： 1.自研的流式框架td-etl-framework有哪些局限？ 2.为什么我们会选择Flink? 3.迁移至JSON SDK时出现了哪些问题？ ...

林宝宝 2019-8-30 1 4556

问题导读 1.Apache Flink 1.9.0 有什么样的里程碑意义？ 2.Apache Flink 1.9.0 有哪些重点改动？ 3.Apache Flink 1.9.0 ...

fc013 2019-9-20 2 4556

问题导读 1.Flink写redis需要什么组件？ 2.Flink Redis Connector支持哪三种Redis连接方式？ 3.Flink Redis Sink 用法有哪 ...

pig2 2020-8-26 0 4550

本帖最后由 pig2 于 2019-3-5 18:25 编辑 问题导读 1.OrderBy, Offset & Fetch作用是什么？ 2.Insert可以干什么事情？ 3.如 ...

pig2 2019-3-4 1 4433

问题导读 1.本文涉及哪些技术点？ 2.如何实现统计热门商品的TopN？ 3.如何实现窗口排序？ 文章目录 一、需求说 ...

nettman 2020-6-18 1 4372

问题导读 1.Flink 1.9之前的版本处流处理和批处理API是否相同？ 2.自flink 1.9之后的版本新增了什么内容？ 3.blink planner ...

nettman 2020-5-7 2 4369

问题导读 1.输出模式包含哪两种？ 2.输出行的schema包含哪些列？ 3.什么是模式变量？ 上一篇：彻底明白Flink系统学习29- ...

pig2 2019-1-30 2 4329

问题导读 1.FlinkCEP是什么？ 2.FlinkCEP解决了什么问题？ 3.FlinkCEP该如何使用？ 0. 本文概述简介 FlinkCEP是在Fli ...

pig2 2019-5-13 0 4315

问题导读: 1.为什么选择Prometheus？ 2.使用自动发现的配置方式有什么优点？ 3.如何提交作业？ 这篇文章介绍了如何利用Apa ...

Mirinda 2021-2-22 0 4272

本帖最后由 pig2 于 2020-6-3 07:03 编辑 问题导读： 1、数仓架构如何设计？ 2、Hive 实时化如何实现？ 3、Hive 增强如何使 ...

levycui 2020-6-2 0 4269

问题导读： 1、Avro提供的技术支持包括哪些？ 2、Avro优点有哪些？ 3、如何使用Java自定义序列化到kafka？ 4、Flink如何实现 ...

levycui 2021-8-10 0 4225

问题导读 1.Iceberg作为数据落地的格式解决了Flink什么痛点? 2.Flink Iceberg sink有哪些模块？ 3.Flink Iceberg sink如何 ...

nettman 2020-6-9 1 4124

问题导读 1.Flink 在快手有哪些典型应用场景？ 2.快手 Flink 技术演进分为哪几个部分？ 3.怎样利用Flink进行平台化建设 ...

fc013 2019-10-25 1 4082

问题导读 1.LAST函数作用是什么？ 2.FIRST函数的作用是什么？ 3.LAST和FIRST函数使用有哪些需要注意的？ 上一篇： 彻底 ...

pig2 2019-1-31 1 4081

问题导读 1.Flink内存做了哪些优化？ 2.Flink作业提交逻辑抽象到了哪个接口？ 3.Flink 1.10 的 Hive 集成引入了哪些优化？ ...

nettman 2020-2-13 0 4050

本帖最后由 pig2 于 2020-7-14 17:18 编辑 问题导读： 1、 新版本生态完善和易用性有哪些提升？ 2、有哪些全新 Source API？ ...

levycui 2020-7-14 1 4016

问题导读 1.怎样对字段进行大区转换？ 2.怎样拆分打平大JSON? 3.怎样把不同类型的日志数据分别进行存储？ 应用场 ...

fc013 2020-10-23 0 4012

问题导读： 1、Flink Sql解析器是什么？ 2、Flink Planner 和 Blink Planner如何理解？ 3、Calcite的 parse 解析模块是基于什 ...

levycui 2021-10-13 0 3963

问题导读 1.响应式缩放有什么特点？ 2.Flink提供了什么工具用来排查性能问题？ 3.性能分析过程中的哪一部分的操作是昂贵的 ...

nettman 2021-5-10 0 3959

本帖最后由 fc013 于 2020-6-6 09:19 编辑 问题导读 1.什么是 checkpoint？ 2.checkpoint 的注意事项有哪些？ 3.Flink 作 ...

fc013 2020-6-6 1 3916

问题导读 1.Flink中的时态表的设计初衷是什么？ 2.动态表查询是否会终止？ 3.在Flink1.12中，完善了1.11中的不足，在DDL直 ...

Mirinda 2021-3-22 0 3908

问题导读:1.Flink官网提供了什么可视化工具？2.如何获取执行计划 JSON？3.如何禁止 Operator chain？ 当一个应用程序需求比较 ...

Mirinda 2021-3-29 0 3898

问题导读： 1、什么是Lambda架构？ 2、为什么选择Flink? 3、AI Flow工作原理是怎样的？ 导读：在如今的大数据在线和离线场 ...

BGnv5 2020-12-10 0 3889

问题导读: 1. Flink faker作用是什么？ 2.如何启动Zeppelin？ 3.Lateral Table Join sql该如何写？ 对于初学者来说，学习 ...

Mirinda 2021-3-11 0 3887

问题导读： 1、什么是CDC？ 2、代码如何实现？ 3、撤回流怎么确定读取的数据是要被撤回的？ 简介： Flink 1.11 最重要的 F ...

BGnv5 2020-12-17 0 3869