Flink 測試運行,遇到的GC跟taskmanager掛掉問題

1,出現這個,因爲代碼寫的是Json類型,算子與算子之間下發json對象,沒有序列化,都改成pojo 實現序列化,可以減輕內存消耗   2,因爲有個業務是全量統計,會存儲歷史狀態,所以內存要設置大一點,設置 RocksDBStateBackend存儲,設置TTL,之前可能壓力測試3個小時TM就死了,再次測試 超過十幾個小時任務都還比較穩定 3,安裝JVM工具監控JVM的情況,並且在conf文件配
相關文章
相關標籤/搜索