flink 实时查数据库引发的异常
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连接数过多，数据库异常
Kafka开源项目指南提供详尽教程，助开发者掌握其架构、配置和使用，实现高效数据流管理和实时处理。它高性能、可扩展，适合日志收集和实时数据处理，通过持久化保障数据安全，是企业大数据生态系统的核心。
更多推荐
0
0- 0
已为社区贡献3条内容
所有评论(0)