FlinkKafkaProducer实现了TwoPhaseCommitSinkFunction，也就是两阶段提交。关于两阶段提交的原理，可以参见《An Overview of...
IP属地：广东
-
Flink kafka端到端Exactly-Once源码分析 -
Flink kafka sink源码解析
初始化 通常添加一个kafka sink的代码如下： 初始化执行env.addSink的时候会创建StreamSink对象，即StreamSink<T> sinkOperat...
-
Flink StreamTask OperatorChain分析
Flink的作业StreamTask是任务执行的核心，其执行的本质即为各个operator的执行，而operator之间又有前后依赖关系，各operator构成一条链条（Ch...
-
Flink使用GCS作为state backend
由于项目的原因，需要将Flink运行在GCP上，因此File System自然是想使用GCS. 在网上搜了很多，由于众所周知的原因，国内使用Google Cloud非常少，资...
-
K8s service catalog
Service catalog Service catalog: https://github.com/kubernetes-incubator/service-catalo...
-
Kafka-client 0.10.0 API问题
注：本文涉及到的环境版本为kafka 0.10.0在使用kafka 0.10.0 API获取consumer offset的时候，遇到卡住的问题，类似KAFKA-3296-A...
-
-
Learning Apache Flink(BASIC)本文是参考Apache Flink v1.3官方文档 1. Dataflows Flink的程序包括两部分，streams和transformations。stream指的就...
