基于flink-1.8.1 概述 parallelism指的是并行度的意思。在 Flink 里面代表每個(gè)任務(wù)的并行度，適當(dāng)?shù)奶岣卟⑿卸瓤梢源蟠筇岣?job 的執(zhí)行效率，比如你...
IP屬地：上海
-
Flink--對parallelism 和 slot的理解 -
如何用Chrome開發(fā)者工具查看 HTTP 請求和響應(yīng)內(nèi)容用 Chrome 發(fā)請求 打開 Network 地址欄輸入網(wǎng)址 在 Network 點(diǎn)擊，查看 request，點(diǎn)擊「view source」終于點(diǎn)了？可以看到請求的前三部分...
-
Java1.8-PriorityQueue源碼解析概述 ??首先，Priority翻譯之后是優(yōu)先級的意思，而PriorityQueue，也就是優(yōu)先級隊(duì)列的意思。優(yōu)先級隊(duì)列，和普通的先進(jìn)先出（FIFO）的隊(duì)列不同，優(yōu)先隊(duì)列每次...
-
mac電腦端安裝flink并運(yùn)行example本文介紹如何在mac電腦端安裝flink、運(yùn)行flink自帶exmaple。 唯一的前置條件為電腦端安裝Java 8.x 。mac電腦端安裝flink命令： 查看flink安...
-
HexStringSplit預(yù)分區(qū)表導(dǎo)讀：本文介紹如何使用hbase自帶的HexStringSplit算法，根據(jù)傳入?yún)?shù)（最小值、最大值、分區(qū)數(shù)量）生成startKey,endKey為16進(jìn)制表示的region...
-
hbase預(yù)分區(qū)誤區(qū)創(chuàng)建預(yù)分區(qū)表的代碼： 執(zhí)行代碼后，table的region分布如下： 當(dāng)我們使用十六進(jìn)制的字符作為rowkey前綴的時(shí)候，就會(huì)發(fā)生熱點(diǎn)分區(qū)的問題。記錄都會(huì)集中在如下四個(gè)reg...
-
你要觀察別人怎么活著
本文整理自張鶴老師的語音分享課。 圍繞莫泊桑的《項(xiàng)鏈》，關(guān)于設(shè)計(jì)人物小傳的問題，我們已經(jīng)做了兩天的分享，鏈接如下： 和你自己筆下的人物談戀愛 你不需要多聰明才能寫作 今天我們...
-
yarn使用cgroup隔離cpu資源yarn默認(rèn)只管理內(nèi)存資源,雖然也可以申請cpu資源,但是在沒有cpu資源隔離的情況下效果并不是太好.在集群規(guī)模大,任務(wù)多時(shí)資源競爭的問題尤為嚴(yán)重.還好yarn提供的Linu...
