是的，1.12已經(jīng)修復(fù)了
解決Flink1.11.0不能指定SQL任務(wù)JobName問題前言： Flink最近剛發(fā)布了1.11.0版本，由于加了很多新的功能闺鲸，對(duì)sql的支持更加全面凤巨，我就迫不及待的在本地運(yùn)行了個(gè)demo癞季，但是運(yùn)行的時(shí)候報(bào)錯(cuò)了： 雖然報(bào)錯(cuò)歼跟，但任務(wù)卻...
發(fā)簡信
IP屬地：廣東
-
-
月更一隨筆文涵紊，周更一技術(shù)文<br><br>閑暇時(shí)刻搭站點(diǎn)：<br><a href="http://yitaicloud.com" rel="nofollow" target="_blank">http://yitaicloud.com</a><br>讀書記錄在豆瓣：<br><a href="https://www.douban.com/people/139549170" rel="nofollow" target="_blank">https://www.douban.com/people/139549170</a><br>開源留爪Github:<br><a href="https://github.com/tisonkong" rel="nofollow" target="_blank">https://github.com/tisonkong</a><br><br>路漫修遠(yuǎn), 道阻且長, 明心見性, 知行合一
-
Mysql的幾個(gè)靈魂拷問（五）這一篇繼續(xù)講SQL的優(yōu)化問題，在常規(guī)應(yīng)用開發(fā)中楚昭，Mysql的單表性能都是夠用的栖袋，從量級(jí)來看，一般以整型值為主的表在千萬級(jí)以下抚太，字符串為主的表在五百萬以下Mysql都是可以的塘幅，...
-
Flink SQL 實(shí)戰(zhàn)之 MAP 類型在 UNION ALL 中的妙用
前言 工作當(dāng)中我們往往會(huì)遇到這樣的需求場景：某張表中不同的統(tǒng)計(jì)指標(biāo)，需要從多個(gè)不同的 kafka 數(shù)據(jù)源當(dāng)中統(tǒng)計(jì)尿贫。這種做法电媳，我們很容易想到把多個(gè) kafka source 統(tǒng)...
-
Flink State機(jī)制源碼解析在流計(jì)算中，事件會(huì)持續(xù)不斷的產(chǎn)生庆亡，如果每次計(jì)算都是相互獨(dú)立的匾乓，不依賴于上下游事件，則稱為無狀態(tài) (stateless) 計(jì)算又谋；如果每次的計(jì)算依賴于之前或者后續(xù)的事件拼缝，則稱為有...
-
從一段 Dubbo 源碼到 CPU 分支預(yù)測的一次探險(xiǎn)之旅
從一段 Dubbo 源碼到 CPU 分支預(yù)測的一次探險(xiǎn)之旅 每個(gè)時(shí)代，都不會(huì)虧待會(huì)學(xué)習(xí)的人彰亥。 大家好咧七，我是 yes。 說來也是巧最近在看 Dubbo 源碼任斋，然后發(fā)現(xiàn)了一處很奇...
-
大佬厲害继阻，我當(dāng)時(shí)看到dubbo的這段代碼的時(shí)候也是一樣，不知道為啥這樣，也沒去深究瘟檩，今天學(xué)到了抹缕。??
從一段 Dubbo 源碼到 CPU 分支預(yù)測的一次探險(xiǎn)之旅
從一段 Dubbo 源碼到 CPU 分支預(yù)測的一次探險(xiǎn)之旅 每個(gè)時(shí)代，都不會(huì)虧待會(huì)學(xué)習(xí)的人墨辛。 大家好卓研，我是 yes。 說來也是巧最近在看 Dubbo 源碼背蟆，然后發(fā)現(xiàn)了一處很奇...
-
大神鉴分，請(qǐng)教個(gè)問題，stream api的 innor join和 left join都需要開開窗带膀，
在sql里志珍，可以直接 join和left join，并沒有開窗垛叨，那這個(gè)底層是怎么實(shí)現(xiàn)的呢談?wù)凢link DataStream API中的三種雙流join操作
前言 本文是基礎(chǔ)中的基礎(chǔ)伦糯，看官可以放心食用。 在數(shù)據(jù)庫中的靜態(tài)表上做OLAP分析時(shí)嗽元，兩表join是非常常見的操作敛纲。同理，在流式處理作業(yè)中剂癌，有時(shí)也需要在兩條流上做join以獲得...
-
建設(shè)實(shí)時(shí)數(shù)倉之前的思考與方案記錄前言 隨著這次新冠疫情帶來的機(jī)遇淤翔，我司業(yè)務(wù)飛速增長，實(shí)時(shí)數(shù)倉的建設(shè)已經(jīng)提上了日程佩谷。雖然還沒有正式開始實(shí)施旁壮，但是汲取前人的經(jīng)驗(yàn)，做好萬全的準(zhǔn)備總是必要的谐檀。本文簡單松散地記錄一下...
-
深入理解Java內(nèi)存模型java內(nèi)存模型(Java Memory Model桐猬，JMM)是java虛擬機(jī)規(guī)范定義的麦撵，用來屏蔽掉java程序在各種不同的硬件和操作系統(tǒng)對(duì)內(nèi)存的訪問的差異，這樣就可以實(shí)現(xiàn)j...
-
深入理解Flink的輕量級(jí)異步屏障快照（ABS）算法Prologue 在很久之前溃肪，筆者曾簡單介紹了Chandy-Lamport分布式快照算法免胃，如果看官還未讀過，建議作為前置知識(shí)補(bǔ)充一下惫撰。 用過Flink的人都會(huì)知道檢查點(diǎn)機(jī)制有...
-
淺談Java SPI原理與其在JDBC羔沙、Flink中的應(yīng)用API vs SPI API（Application Programming Interface）的概念對(duì)我們來說已經(jīng)是見怪不怪了。在日常開發(fā)過程中润绎，我們需要調(diào)用平臺(tái)/框架提...
-
Flink流量控制與反壓機(jī)制完全總結(jié)前言 筆者最近回顧自己對(duì)Flink技術(shù)棧細(xì)節(jié)的理解，發(fā)現(xiàn)對(duì)Flink的網(wǎng)絡(luò)棧、流控與反壓這一套機(jī)制存在比較大的盲區(qū)莉撇。雖然平時(shí)多次處理過作業(yè)反壓的問題呢蛤，但是不完全理解背后的實(shí)現(xiàn)...
-
贊其障，小魔法。balabala小魔仙
Flink流量控制與反壓機(jī)制完全總結(jié)
前言 筆者最近回顧自己對(duì)Flink技術(shù)棧細(xì)節(jié)的理解涂佃，發(fā)現(xiàn)對(duì)Flink的網(wǎng)絡(luò)棧励翼、流控與反壓這一套機(jī)制存在比較大的盲區(qū)。雖然平時(shí)多次處理過作業(yè)反壓的問題辜荠，但是不完全理解背后的實(shí)現(xiàn)...
-
flink的背壓問題產(chǎn)生原因與解決方法最近flink job出現(xiàn)了背壓的問題, 后果是導(dǎo)致了checkpoint的生成超時(shí), 影響了flink job的運(yùn)行. 定位問題: 如下圖: 1) flink的checkp...
