?

我們常常會(huì)看到這樣的界面

?

?

那么這里面的兩個(gè)方塊(也就是slot)的顏色，以及方塊中的兩個(gè)數(shù)字6到底是什么鬼？
這些方塊有個(gè)專門的叫法:slot
這些slot的顏色表述數(shù)據(jù)分區(qū)partition的key[1]
分區(qū)數(shù)量是根據(jù)輸入數(shù)據(jù)來(lái)定的，顏色不代表特別的含義，只是表示某個(gè)特定的partition的key

?

好了，那么這些方塊中的顏色是什么意思呢？

slot的顏色的含義在[4](我在[3]中提到了這個(gè)問題)

含義	顏色代碼	slot顏色
TOTAL	#112641
RUNNING	#52c41a
FAILED	#f5222d
FINISHED	#1890ff
CANCELED	#fa8c16
CANCELING	#faad14
CREATED	#2f54eb
DEPLOYING	#13c2c2
RECONCILING	#eb2f96
IN_PROGRESS	#faad14
SCHEDULED	#722ed1
COMPLETED	#1890ff
RESTARTING	#13c2c2

?

配置文件$FLINK_HOME/conf/flink-conf.yaml里面的是每個(gè)task manager可用的slot數(shù)量,是上限值。
web ui里面的是根據(jù)需要分配的slot。
一個(gè)task處理一個(gè)partition.
partition的key是顏色，也就是web ui上方塊的顏色。

方塊上的數(shù)字6，是串行執(zhí)行的task數(shù)量(從輸入task一直到輸出task),6具體的含義如下:

看到右側(cè)的數(shù)字沒?

1+2+2+1=6

這個(gè)6就是前面一張插圖中slot中的數(shù)字的含義，表示整個(gè)流程從頭到尾總共有6個(gè)task。

###############################################################################3

另外，自己的一點(diǎn)感悟:

?

可以參考上圖spark來(lái)理解，
flink運(yùn)行的某個(gè)時(shí)刻，task和partition也是一一對(duì)應(yīng)的。

如果從整個(gè)處理過程來(lái)看，那task數(shù)量當(dāng)然與partition數(shù)量不一致,前者是6/slot,后者是2.

Reference:

[1]Apache Flink Series 3 — Architecture of Flink

[2]Flink--對(duì)parallelism 和 slot的理解

[3]what's the meaning of different color in FLINK WEB UI

[4]https://github.com/apache/flink/blob/master/flink-runtime-web/web-dashboard/src/app/app.config.ts

?

?

?

總結(jié)

以上是生活随笔為你收集整理的flink的web ui中五颜六色的方块是什么意思？的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。