LittleMagic

實時作業(yè)要保證7 x 24運行，除了要在業(yè)務(wù)邏輯和編碼上下功夫之外，好的監(jiān)控系統(tǒng)也是必不可少的。Flink支持多種匯報監(jiān)控指標（metrics）的reporter，如JMX腺劣、...

LittleMagic

前言 雖然筆者之前寫過基于Prometheus PushGateway搭建Flink監(jiān)控的過程，但是在我們的生產(chǎn)環(huán)境中，使用的是InfluxDB扣猫。InfluxDB是一個由Go...

LittleMagic

本文已授權(quán)「Flink中文社區(qū)」微信公眾號發(fā)布并標注原創(chuàng)。 前言 今天本來想搞篇走讀StreamingFileSink源碼的文章翘地，但是考慮到Flink 1.11版本發(fā)布已經(jīng)有...

LittleMagic

Foreword Flink SQL之所以簡潔易用而功能強大申尤，其中一個重要因素就是其擁有豐富的Connector（連接器）組件。Connector是Flink與外部系統(tǒng)交互的...

LittleMagic

前言 大數(shù)據(jù)領(lǐng)域SQL化開發(fā)的風潮方興未艾（所謂"Everybody knows SQL"）衙耕，F(xiàn)link自然也不能“免俗”昧穿。Flink SQL是Flink系統(tǒng)內(nèi)部最高級別的A...

LittleMagic

前言 之前的文章中已經(jīng)屢次提到過Flink的事件時間（event time）橙喘、水邮蓖摇（watermark）、亂序（out-of-order）厅瞎、遲到數(shù)據(jù)（late element...