SparkStreaming对接Redis致使redis链接数不断上升

redis链接数 出现缘由:在partition中经过新建对象建立redis链接池!使用完后,未完全关闭链接池,致使随着批次增长,redis链接数也不断增长。 解决办法:手动调用close或destroy()web def destroyPool(): Unit ={ if(pool != null){ pool.close() } }
相关文章
相关标签/搜索