问题导读： 1.Flink如何连接hive? 2.识别不到 Hadoop 环境或配置文件找不到怎么处理？ 3.依赖包、类或方法找不到怎么办？ ...

BGnv5 2020-5-18 1 2688

问题导读 1.Flink中的组件是怎样交互的？ 2.Flink任务的处理流程是怎样的？ 3.Flink各个节点之间是如何进行传递的？ ...

fc013 2020-8-8 0 2673

问题导读 1.了解sqlClient 代码有哪些好处？ 2.如何添加启动类运行需要的参数和依赖包？ 3.如何Debug Flink 1.12 源码？ ...

nettman 2021-3-29 0 2660

很多老铁希望了解一些应用，这里给大家分享下Flink基础教程的一个案例，希望大家可以对Flink应用，可以进一步的了解一些案例。 ...

pig2 2019-11-26 0 2631

本帖最后由 levycui 于 2020-7-21 15:21 编辑 问题导读： 1、如何配置 Flink 进程的内存？ 2、如何配置总内存？ 3、如何配 ...

levycui 2020-7-21 0 2624

问题导读： 1、Hudi 实时写入有哪些痛点？ 2、怎样优化 Hudi 的写入流程？ 3、BitSail有哪些功能？ 1. 导读 ...

fc013 2022-12-10 0 2676

问题导读： 1、如何理解CDC 和数据湖？ 2、CDC面临的技术挑战是什么？ 3、Schema evolution可以分哪几种？ 4、Flink未来计划 ...

levycui 2021-4-20 0 2520

本帖最后由 levycui 于 2021-11-17 10:21 编辑 问题导读： 1、Flink CDC是什么？ 2、Flink CDC 2.1有哪些新功能？ 3、MySQL ...

levycui 2021-11-17 0 2507

问题导读 1.Flink CDC底层是使用什么来进行数据变化更改？ 2.如何添加Flink CDC依赖？ 3.如何使用SQL方式同步Mysql数据到 ...

nettman 2022-10-9 1 2435

本帖最后由 levycui 于 2020-6-30 23:26 编辑 问题导读： 1、实时数仓建设目的是什么？ 2、如何建立实时数仓？ 3、仓库质量 ...

levycui 2020-6-30 0 2454

问题导读 1.Barrier 对齐会造成什么问题？ 2.Barrier 对齐是否会造成反压？ 3.如何理解Unaligned Checkpoint ？ 作为 ...

阿飞 2020-7-13 0 2438

问题导读： 1.StreamOperator是什么接口？ 2.AbstractStreamOperator是什么抽象实现类？ 3.StreamOperator继承哪些接口? ...

hanyunsong 2020-8-10 0 2409

本帖最后由 levycui 于 2021-3-24 19:07 编辑 问题导读： 1、什么是Hive Catalog？ 2、如何使用Hive Catalog？ 3、什么是Hi ...

levycui 2021-3-24 0 2396

问题导读： 1、如何保证前后两次提交生成算子稳定的对应关系呢？ 2、如何把 checkpoint 写入公共 HDFS，把业务数据写入另 ...

fc013 2021-9-17 0 2404

问题导读：1.你有没有阅读源码的习惯？2.有阅读过kafka源码吗？3.你对文中的自定义序列化类有什么看法？ 在最近发布的 Flink 1. ...

Mirinda 2021-10-14 0 2374

问题导读： 1、Flink CDC 2.3 版本有哪些重大改进和核心特性？ 2、Flink CDC 2.3 版本中MySQL CDC 连接器有哪些优化？ 3 ...

fc013 2022-12-3 1 2315

问题导读： 1、为什么要做Flink和Hive集成？ 2、Flink 1.11中的新特性有哪些？ 3、如何打造Hive批流一体数仓? 导读：Flink ...

BGnv5 2020-11-2 0 2295

问题导读 1.在 Flink 中需要端到端精准一次处理的位置有哪三个？ 2.Flink端到端精准一次处理语义（EOS）包含哪些内容？ 3. ...

hyj 2022-6-5 1 2287

问题导读 1、Flink 如何在 K8S 的 POD 中与 HDFS 交互？ 2、Flink on K8S 怎么保证 HA？ 3、Flink on K8S 和 Flink on YARN， ...

nettman 2020-5-28 1 2253

2023 年 3 月 12 日，Flink Table Store 项目顺利通过投票，正式进入 Apache 软件基金会 (ASF) 的孵化器，改名为 Apache Paimon ...

nettman 2023-3-27 0 2194

问题导读： 1.小米大数据发展演变经历了那些过程？ 2.什么是流批一体的平台？ 3.流批一提平台有哪些应用场景？ 摘要： ...

Mirinda 2022-4-21 0 2152

问题导读 1.Fink CDC 2.0 实现了拿三个重要功能？ 2.本文使用Hudi什么能力？ 3.37 手游的业务痛点是什么？ 4..37 手游技 ...

阿飞 2021-9-22 0 2085

问题导读： 1、什么是数据湖？为什么数据湖近两年热度很高？ 2、Flink Hudi 的写入 pipeline 由几个算子构成？ 3、Flink Hudi ...

levycui 2022-2-16 0 2058

问题导读： 1、Kafka 代理、生产者、消费者和 AdminClient有哪些变化？ 2、Kafka Streams有哪些调整？ 3、外键连接中的自定义 ...

levycui 2022-1-26 0 2021

问题导读： 1.工作中使用Flink吗？ 2.使用Flink过程中遇到那些瓶颈？ 3.如何解决Flink的瓶颈的？ 随着 Flink 流批一体架构 ...

Mirinda 2022-1-10 0 1991

问题导读： 1、Lambda 架构有哪些缺陷？ 2、流批一体技术面临哪些挑战？ 3、FlinkSQL需要做哪些优化？ 01 整 ...

fc013 2022-7-1 0 1997

问题导读： 1、什么是细粒度资源管理？ 2、Flink 的资源调度框架中有哪些角色？ 3、Flink怎样实现的细粒度资源管理？ ...

fc013 2022-2-18 0 1963

一、自适应执行计划 我们先看一下，Flink 是如何描述作业的执行计划的。以这个 DataStream 作业为例，Flink 会基于它先生 ...

阿飞 2023-1-11 0 1979

问题导读 1.Hybrid Source是什么源？ 2.Buffer Debloating作用是什么? 3.什么功能可以提高大型共享集群的资源利用率？ ...

nettman 2021-10-7 1 1942