问题导读： 1、新 Blink Planner 实现哪些增强功能？ 2、Flink在对象重用场景中的优势是什么？ 3、如何与 DataStream API相结 ...

levycui 2020-3-11 1 6451

问题导读： 1、如何配置内存？ 2、如何设置并行度？ 3、如何配置进程参数？ 4、如何设计分区方法？ 一 配置内存 操作场景 Fli ...

levycui 2021-4-6 1 6345

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

pig2 2021-3-22 3 6334

问题导读： 1、StreamTask的层级结构如何理解？ 2、StreamTask生命周期的抽象方法如何实现？ 3、Java泛型类型擦除如何实现？ ...

levycui 2020-8-11 0 6082

问题导读： 1、Flink 内存数据结构如何理解？ 2、网络缓冲器(NetworkBuffer)是什么？ 3、Flink 内存如何进行调优？ 4、故障 ...

levycui 2021-10-12 1 6096

问题导读： 1、什么样的业务场景适合？ 2、常见的实时数仓方案有哪些？ 3、为什么选择Flink+Clickhouse？ 4、踩过的“坑”有 ...

levycui 2021-5-13 1 6065

问题导读： 1、Flink SQL 空闲状态保留时间如何设置？ 2、空闲状态参数如何配置？ 3、如何理解空闲状态保留时间实现原理？ 4 ...

levycui 2019-12-31 2 6044

问题导读 1.Pattern与NFA的关系是什么？ 2.每个状态有哪几个迁移边？ 3.本文如何使用CEP实现空气质量检测？ 概念介 ...

阿飞 2019-7-18 1 6023

问题导读 1.本文是基于哪个版本的例子？ 2.新版本使用了哪个函数来处理逻辑？ 3.是否支持select和flatSelect? 4.下面例子 ...

pig2 2019-10-8 2 5888

问题导读: 1. 如何创建创建执行环境？ 2. 如何创建 Kafka 流表？ 3. 如何创建 Hive 表？ 4. 如何流式写入 Hive？ 5. 如何 ...

hanyunsong 2020-7-23 0 5887

问题导读 1.有界批量输入还是无界流输入，表API和SQL查询都有什么特点？ 2.状态的本质是什么？ 3.连续查询的准确性和资源消 ...

pig2 2019-2-14 1 5822

问题导读： 1、如何从 Kafka 读取数据写出到Hudi表？ 2、启动时需要准备什么？ 3、如何启动任务并查看进程？ 近日Apache H ...

BGnv5 2020-12-14 1 5754

问题导读 1.实现异常报警本文采用了那种方法？ 2.采用window是如何实现的？ 3.采用keyedstream是如何实现的？ 问题定 ...

hyj 2020-4-16 1 5683

问题导读 1.写成的监控体系存在哪些问题？ 2.为什么最终选择了 Flink？ 3.Prophet 操作流程是怎样的？ Flink 已经 ...

a87758133 2019-7-29 1 5678

问题导读： 1、顺丰的架构是怎样的？ 2、Hudi on Flink是什么？ 3、产品化支持都包括什么？ 本文主要介绍顺丰在数据仓库的 ...

BGnv5 2020-12-21 0 5660

问题导读： 1、如何做好回撤机制？ 2、如何优化维表关联？ 3、如何进行数据倾斜治理？ 4、如何解决超时统计瓶颈？ 菜 ...

levycui 2019-10-22 2 5623

问题导读 1.流处理和批处理是否使用同一套table API？ 2.是否所有算子都可以用于流处理和批处理？ 3.本文讲了哪些聚合算子 ...

pig2 2019-2-25 0 5573

问题导读 1.Pulsar是什么组件？ 2.Pulsar作为Flink Catalog，有哪些好处？ 3.Flink是否直接使用Pulsar原始模式？ 4.Flink ...

pig2 2020-1-13 0 5313

问题导读 1.在Kubernetes上运行Flink有哪些挑战？ 2.为何我们选择将Flink作为作业集群运行？ 3.在Kubernetes上是否可以运 ...

pig2 2019-4-28 1 5244

问题导读 1.匹配模式有哪些匹配策略？ 2.MATCH_RECOGNIZE子句是否可以使用已配置的状态保留时间？ 3.匹配模式有哪些不支持 ...

pig2 2019-2-1 0 5231

问题导读 1.如何实现flink的动态加载jar？ 2.flink -C 参数的作用是什么？ 3.源码pipeline.classpaths有什么发现？ 背 ...

hyj 2020-12-31 1 5226

问题导读： 1、如何理解Apache Flink 的架构及原理？ 2、如何理解「有状态的流式处理」概念解析？ 3、Apache Flink 的优势有 ...

levycui 2019-7-9 0 5193

本帖最后由 BGnv5 于 2019-5-4 11:38 编辑 问题导读 1.G7是如何工作的？2.G7的业务场景是怎样的？3.哪一种流计算框架比较适 ...

BGnv5 2019-5-4 1 5121

问题导读 1.怎样使用Flink实现WordCount程序？ 2.怎样搭建Flink集群？ 3.Flink怎样整合Kafka？ 上一篇：Flink入 ...

fc013 2019-12-27 2 5082

本帖最后由 levycui 于 2020-6-10 19:39 编辑 问题导读： 1、如何使用 Maven 构建的 Flink 项目？ 2、如何进行common module ...

levycui 2020-6-10 2 5079

问题导读 1.什么是Pulsar？ 2.Pulsar都有哪些概念？ 3.Pulsar有什么特点？ 4.Flink未来如何与Pulsar整合？ Apache F ...

pig2 2019-5-5 1 5022

本帖最后由 pig2 于 2019-2-28 11:51 编辑 问题导读 1.Join算子有哪些？ 2.内联和外联有什么区别？ 3.时间窗口连接有什么 ...

pig2 2019-2-28 1 4994

问题导读： 1、怎样实现基于 Flink SQL CDC 的数据同步方案？ 2、CDC 是否需要保证顺序化消费？ 3、GROUP BY 结果如何写 ...

fc013 2021-5-21 0 4951

本帖最后由 levycui 于 2020-11-4 22:12 编辑 问题导读： 1、Flink1.11如何将 聚合，update数据写入到kafka？ 2、Flink 1.11 ...

levycui 2020-11-4 0 4925