Flink Kafka 端到端 Exactly
摘要：本文基于Flink1.9.0和Kafka2.3版本，对Flinkkafka端到端ExactlyOnce进行分析及 notifyCheckpointComplete顺序，主要内容分为以下两部分：1.Flinkkafka两阶段提交源码分析TwoPhaseCommitSinkFuncti
Flink+Kafka整合的实例
FlinkKafka整合实例1.使用工具IntelligIDEA新建一个maven项目，为项目命名为kafka01。2.我的pom.xml文件配置如下。<?xmlversion"1.0"encoding"UTF8"?<projectxmlns"http://maven.apache.org/POM/4
Flink读取数据存入Redis中
1.环境准备: 1.搭建单机版的Redis 2.虚拟机上ncl9000方式产生数据2.需求分析：通过socket的ncl9000方式产生数据，然后将数据以list的形式存入到Redis中3.flink依赖的redis的pom文件 redis的依赖(https://www.oschina.net/ac
Flink Forward 201812 PPT资料下载
FlinkForward201812PPT资料下载：下载地址一：http://cdn.iteblog.com/FlinkForward201812.7z下载地址二：链接：https://pan.baidu.com/s/1aiCpN6eaclCeBq4OXw1Wg提取码：a2kh!(https://oscimg.oschina.n
Flink 中定时加载外部数据
社区中有好几个同学问过这样的场景： flink任务中，source进来的数据，需要连接数据库里面的字段，再做后面的处理这里假设一个ETL的场景，输入数据包含两个字段“type,userid....”，需要根据type，连接一张mysql的配置表，关联type对应的具体内容。相对于输入数据的数量，type的值是很少的
Golang 常用的第三方包.
Goland下面这个licenseserver可用http://idea.youbbs.org(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Flink.jianshu.com%3Ft%3Dhttp%253A%252F%252Fidea.youbbs.org)(20180
Storm VS Flink ——性能对比
!(https://oscimg.oschina.net/oscnet/2cec00eb2dccf5fdec8def77207da253a86.jpg)1.背景ApacheFlink和ApacheStorm是当前业界广泛使用的两个分布式实时计算框架。其中ApacheStorm（以下简称“Storm”）在美团点评实时
GitHub学习使用笔记
一、界面!(https://static.oschina.net/uploads/space/2017/0331/105607_sMsr_3184390.png)二、下载版本管理工具GitHubDesktop(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Flink.z
Sublime Text Build 3033完美破解含KEY
DOWNLOAD: http://pan.baidu.com/share/link?shareid528115&uk1745976571(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fpan.baidu.com%2Fshare%2Flink%3Fshareid%3D528115%26