flink數據聚合遇到的數據過熱,延遲數據丟棄, 反壓等問題如何解決

首先解釋一下數據過熱、延遲數據丟棄和數據反壓的產生原因: 1.數據過熱原因: 實時處理中的關鍵問題是檢測數據流中的事件模式。複雜事件處理(CEP)恰好解決了對連續傳入事件進行模式匹配的問題。 匹配的結果通常是從輸入事件派生的複雜事件。 與對存儲數據執行查詢的傳統DBMS相比,CEP在存儲的查詢上執行數據。 可以立即丟棄與查詢無關的所有數據。 考慮到CEP查詢應用於潛在的無限數據流,這種方法的優勢是
相關文章
相關標籤/搜索