痛點(diǎn)：假如我們在FLink的WebUI Metrics頁面發(fā)現(xiàn)有一個SubTask每秒處理的數(shù)據(jù)明顯比其他低，又或者在CheckPoint頁面，發(fā)現(xiàn)有一個SubTask的Ch...
發(fā)簡信
IP屬地：廣東
-
Flink如何快速定位SubTask在哪臺機(jī)器哪個進(jìn)程中執(zhí)行 -
Flink 流流關(guān)聯(lián)( Interval Join)總結(jié)
Flink對流流JOIN的支持 Flink對于join的支持有多種支持，可參考 Flink Join類型， 本文主要討論Time interval join支持Table A...
-
Kafka+Spark Streaming如何保證exactly once語義在Kafka、Storm、Flink、Spark Streaming等分布式流處理系統(tǒng)中（沒錯，Kafka本質(zhì)上是流處理系統(tǒng)，不是單純的“消息隊(duì)列”），存在三種消息傳遞語義（...
-
離線部署 Cloudera Manager 5 和 CDH 5.12.1 及使用 CDH 部署 Hadoop 集群服務(wù)歷時一天半，著實(shí)廢了不少功夫。整個搭建過程，是參考這篇文章和大神的部署文檔。 一、系統(tǒng)環(huán)境配置 前提是/etc/hostname已經(jīng)修改過了。并且要注意，hostname中不...
-
MySQL binlog 增量數(shù)據(jù)解析服務(wù)MySQL binlog 增量數(shù)據(jù)解析服務(wù) 介紹如何借助于 MySQL 的 Master-slave 協(xié)議實(shí)現(xiàn) MySQL 增量數(shù)據(jù)獲取服務(wù) 1. 起因 做過后端開發(fā)的同學(xué)都...
-
Hbase技術(shù)詳細(xì)學(xué)習(xí)筆記最近在逐步跟進(jìn)Hbase的相關(guān)工作，由于之前對Hbase并不怎么了解，因此系統(tǒng)地學(xué)習(xí)了下Hbase，為了加深對Hbase的理解，對相關(guān)知識點(diǎn)做了筆記，并在組內(nèi)進(jìn)行了Hbase...
