相当于mysql-cdc的大动作(后面我会讲)，我读源码之后发现, 这个mongoDb-cdc的实现（2.2.1）代码不是很复杂，现在简单记录一下，方便自己后续查阅。 如何开...
发简信
IP属地：广东
-
flink-cdc 之mongoDb源码分析-1 -
FLINK-CDC 之 MongoDB
MongoDB CDC 连接器允许从 MongoDB 读取快照数据和增量数据。 依赖项 为了设置 MongoDB CDC 连接器，下表提供了使用构建自动化工具（例如 Mave...
-
-
-
资深公考老师，助您成功上岸
-
每天记录点滴，记录学习，记录成长。
-
kafka全面认知什么是Kafka[#---kafka] Kafka的应用场景[#kafka-----] Kafka的架构[#kafka---]consumer的pull模式和push模式的区...
-
积累，，，，
-
Hadoop - HDFS分布式存储、HA架构原理、YARN调度原理
Hadoop 的组成 HDFS管理者:namenode工作者:DataNode辅助管理者:secondaryNameNode MapReduce YARN管理者:Resour...
-
本地k8s（v1.12官网译文）
该页面介绍了如何在Kubernetes上本地部署Flink。 入门 本入门部分将指导您在Kubernetes上设置功能齐全的Flink集群。 介绍 Kubernetes是一种...
-
我是一名大数据开发工程师，我在简书会分享一些我平常在工作用到的技术，以及后面会分享一些源码内容。我也在GitHub上搭建了我自己的代码仓库，里面有优秀的项目会记录我是如何从0到1走向大数据架构师（<a href="https://links.jianshu.com/go?to=https%3A%2F%2Fgithub.com%2Flhh2002" target="_blank">https://github.com/lhh2002</a>），我也开通的我自己的公众号【大数据老哥】优秀的文章会第一时间在公众号发布，欢迎大家来观看。
-
zookeeper1 ZK到底是啥？ zookeeper是个服务，服务的对象我们都称为客户端，在大数据生态里面的客户，hadoop、hbase、hive…组件都是分布式部署，这些组件们利用zo...
-
5 一文看完flink的内存管理背景 1）java对象的存储密度比较低，对象主要包含 对象头，对象数据，对齐填充。 其中对齐填充是没用的，纯粹是为了让对象的大小到达8的倍数 2）Full GC非常影响性能，...
-
4 checkpoint 和state的那些事儿本文主要参考唐云《flink checkpoint 轻量级分布式快照》，严禁转载，违者必究 checkpoint 是flink的一个执行操作，动作是去 保存分布式状态的快照 ...
-
3 on yarn的任务提交过程1 client向yarn提交相应的Job 2 client上传jar和配置 3ResourceManager分配Container资源并通知对应的NodeManager启动...
-
2 jobmanager的全部职责1 和client的交互 客户端负责将任务提交到集群，与 JobManager 构建 Akka 连接，然后将任务提交到 JobManager，通过和 JobManager 之...
-
-
FlinkSQL 平台
背景 由于公司内部需求较多，并不想每次都写一个 streaming 程序，故而开始搭建 flinksql 平台，基于 jdk1.8，flink1.12.x 效果 传一个 sq...
-
Flink 架构--官网译文(v1.11)Flink是一个分布式系统，需要有效分配和管理计算资源才能执行流应用程序。 它与所有常见的群集资源管理器（如Hadoop YARN，Apache Mesos和Kubernet...
