雲星數據---Apache Flink實戰系列(精品版)】:Flink其他操作及內容004-flink的背壓機制002

flink背壓的兩種場景 1.本地傳輸 如果task1和task2都運行在同一個工作節點(TaskManager),緩衝區可以被直接共享給下一個task,一旦task 2消費了數據它會 被回收。如果task 2比task 1慢,buffer會以比task 1填充的速度更慢的速度進行回收從而迫使task 1降速。 2.網絡傳輸 如果task 1和task 2運行在不同的工作節點上。一旦緩衝區內的數據
相關文章
相關標籤/搜索