RichSinkFunction中open和close方法，数据库连接

朋友问我一个问题：

RichSinkFunction close只有任务结束时候才会去调用，但是数据库连接一直拿着，最后成了数据库连接超时了，有什么好的建议去处理吗？

 解答：

使用连接池，每次使用的时候是从连接池获取连接，open 方法不是用来获取连接的而是初始化连接池，你应该在你的 invoke 里面 getConnection 然后用完之后 close。