痛點:假如我們在FLink的WebUI Metrics頁面發(fā)現(xiàn)有一個SubTask每秒處理的數(shù)據(jù)明顯比其他低,又或者在CheckPoint頁面,發(fā)現(xiàn)有一個SubTask的Ch...
Flink對流流JOIN的支持 Flink對于join的支持有多種支持,可參考 Flink Join類型, 本文主要討論Time interval join支持Table A...
在Kafka、Storm、Flink、Spark Streaming等分布式流處理系統(tǒng)中(沒錯,Kafka本質(zhì)上是流處理系統(tǒng),不是單純的“消息隊列”),存在三種消息傳遞語義(...
不知道你有沒有配置cdh的本地yum源,沒配置的話遠(yuǎn)程下載會比較慢
離線部署 Cloudera Manager 5 和 CDH 5.12.1 及使用 CDH 部署 Hadoop 集群服務(wù)歷時一天半,著實廢了不少功夫。整個搭建過程,是參考這篇文章和大神的部署文檔。 一、系統(tǒng)環(huán)境配置 前提是/etc/hostname已經(jīng)修改過了。并且要注意,hostname中不...
歷時一天半,著實廢了不少功夫。整個搭建過程,是參考這篇文章和大神的部署文檔。 一、系統(tǒng)環(huán)境配置 前提是/etc/hostname已經(jīng)修改過了。并且要注意,hostname中不...
MySQL binlog 增量數(shù)據(jù)解析服務(wù) 介紹如何借助于 MySQL 的 Master-slave 協(xié)議實現(xiàn) MySQL 增量數(shù)據(jù)獲取服務(wù) 1. 起因 做過后端開發(fā)的同學(xué)都...
最近在逐步跟進(jìn)Hbase的相關(guān)工作,由于之前對Hbase并不怎么了解,因此系統(tǒng)地學(xué)習(xí)了下Hbase,為了加深對Hbase的理解,對相關(guān)知識點做了筆記,并在組內(nèi)進(jìn)行了Hbase...
@仁兄任性 validationQuery為什么是select 'x' 呢,不是select 1么,因為這個配置是驗證連接的有效性的
Spring Boot多數(shù)據(jù)源配置及No operations allowed after connection closed連接異常的解決Spring boot的單數(shù)據(jù)源配置比較簡單,只需要在application.properties配置相關(guān)的jdbc連接的參數(shù)即可,下面簡單的介紹下spring boot的J...