FlinkKafkaProducer實現了TwoPhaseCommitSinkFunction，也就是兩階段提交。關于兩階段提交的原理，可以參見《An Overview of...
IP屬地：廣東
-
Flink kafka端到端Exactly-Once源碼分析 -
Flink kafka sink源碼解析
初始化 通常添加一個kafka sink的代碼如下： 初始化執(zhí)行env.addSink的時候會創(chuàng)建StreamSink對象，即StreamSink<T> sinkOperat...
-
Flink StreamTask OperatorChain分析
Flink的作業(yè)StreamTask是任務執(zhí)行的核心，其執(zhí)行的本質即為各個operator的執(zhí)行，而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問題
注：本文涉及到的環(huán)境版本為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指的就...
