flink 实时查数据库引发的异常

1.flink实时从kafka接收数据，插入mysql ,引用

HikariDataSource dataSource=baseConf.baseMysqlDs();
 Connection connection=HikariCpPool.getConnect(dataSource);

没有关闭数据库连接，插入一万条数据，创建一万条连接，造成mysql连接数过多，数据库异常