下午和朋友聊天的時(shí)候，有朋友提到了約瑟夫環(huán)問(wèn)題。你和另外 n-1 個(gè)人圍成一個(gè)圈，按 1，2，...，n 依次編號(hào)。第一個(gè)人從 1 開(kāi)始報(bào)數(shù)，數(shù)到 k 的人會(huì)被殺掉，然后下一...
發(fā)簡(jiǎn)信
IP屬地：天津
-
約瑟夫環(huán)問(wèn)題的數(shù)學(xué)解 -
Flink 數(shù)據(jù)傳輸及反壓詳解IntermediateDataset IntermediateDataset 是在 JobGraph 中對(duì)中間結(jié)果的抽象。我們知道，JobGraph 是對(duì) StreamGr...
-
用兩階段聚合法解決Flink keyBy()算子傾斜這是上周出現(xiàn)的問(wèn)題了，簡(jiǎn)單做個(gè)記錄。 有一個(gè)按平臺(tái)類(lèi)型實(shí)時(shí)統(tǒng)計(jì)用戶活躍的程序，代碼框架如下。 就是水印→開(kāi)窗→聚合→輸出的經(jīng)典套路。程序正常運(yùn)行一段時(shí)間之后，連續(xù)報(bào)檢查點(diǎn)超時(shí)...
-
Flink Window觸發(fā)機(jī)制
1. Flink的Window類(lèi)型 Flink基本分有3種window類(lèi)型：CountWindow，TimeWindow和SessionWindow。其中，CountWind...
-
探究Flink on YARN模式下TaskManager的內(nèi)存分配一個(gè)問(wèn)題 我們使用如下的參數(shù)提交了Flink on YARN作業(yè)（per-job模式）。 該作業(yè)啟動(dòng)了10個(gè)TaskManager，并正常運(yùn)行。來(lái)到該任務(wù)的Web界面，隨便打...
-
java日期格式Y(jié)YYY與yyyy
常用日期格式：小大小大小小 yyyy-MM-dd HH:mm:ss 【定義】YYYY：以周計(jì)算的年（一周從周日開(kāi)始計(jì)算，周六結(jié)束，只要本周跨年，那么這一周就算下一年的）yyy...
-
TCP的流迭、擁塞處理這篇文章是下篇，所以如果你對(duì)TCP不熟悉的話，還請(qǐng)你先看看上篇《TCP協(xié)議的定義和丟包時(shí)的重傳機(jī)制》 上篇中，我們介紹了TCP的協(xié)議頭、狀態(tài)機(jī)、數(shù)據(jù)重傳中的東西。但是TCP要...
-
TCP協(xié)議的定義和丟包時(shí)的重傳機(jī)制TCP是一個(gè)巨復(fù)雜的協(xié)議，因?yàn)樗鉀Q很多問(wèn)題，而這些問(wèn)題又帶出了很多子問(wèn)題和陰暗面。所以學(xué)習(xí)TCP本身是個(gè)比較痛苦的過(guò)程，但對(duì)于學(xué)習(xí)的過(guò)程卻能讓人有很多收獲。關(guān)于TCP這個(gè)...
