Storm中slot數的擴展

在Storm程序中,用下面語句指定同時處理的worker數:html conf.setNumWorkers(5); 這個worker數受限於slot數量,一個worker消耗一個slot,當slot所有分配完,就不能再加載新的topology。slot數量是在 supervisor.slots.ports 中設置,每一個端口提供一個slot,這樣supervisor數量乘以ports數量,就是st
相關文章
相關標籤/搜索