RichSinkFunction中open和close方法，數據庫連接

朋友問我一個問題：

RichSinkFunction close只有任務結束時候才會去調用，但是數據庫連接一直拿着，最后成了數據庫連接超時了，有什么好的建議去處理嗎？

 

 解答：

使用連接池，每次使用的時候是從連接池獲取連接，open 方法不是用來獲取連接的而是初始化連接池，你應該在你的 invoke 里面 getConnection 然后用完之后 close。