1.flink实时从kafka接收数据，插入mysql ,引用
HikariDataSource dataSource=baseConf.baseMysqlDs();
Connection connection=HikariCpPool.getConnect(dataSource);
没有关闭数据库连接，插入一万条数据，创建一万条连接，造成mysql连接数过多，数据库异常
1.flink实时从kafka接收数据，插入mysql ,引用
HikariDataSource dataSource=baseConf.baseMysqlDs();
Connection connection=HikariCpPool.getConnect(dataSource);
没有关闭数据库连接，插入一万条数据，创建一万条连接，造成mysql连接数过多，数据库异常
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
