SparkStreaming對接Redis致使redis鏈接數不斷上升

redis鏈接數 出現緣由:在partition中經過新建對象建立redis鏈接池!使用完後,未完全關閉鏈接池,致使隨着批次增長,redis鏈接數也不斷增長。 解決辦法:手動調用close或destroy()web def destroyPool(): Unit ={ if(pool != null){ pool.close() } }
相關文章
相關標籤/搜索