下午和朋友聊天的時(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)類型實(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類型 Flink基本分有3種window類型：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è)...
