当前位置:网站首页>Flink同时读取mysql与pgsql程序会卡住且没有日志
Flink同时读取mysql与pgsql程序会卡住且没有日志
2022-04-23 08:47:00 【zs_bigdata】
一. 问题
如题,flink程序会一直卡在initialize阶段,且不会有任何日志
二. 解决
程序中读取mysql与pgsql时使用的方式是:
DriverManager.getConnection(URL, USERNAME, PASSWORD);
测试,如果只请求mysql,或者只请求pgsql就正常有数据,此时我就怀疑是否这个方法有问题
把mysql请求换成使用德鲁伊获取连接
dataSource = new DruidDataSource();
dataSource.setDriverClassName(MysqlConfig.DriverName);
dataSource.setUrl(MysqlConfig.MYSQL_URL);
dataSource.setUsername(MysqlConfig.USERNAME);
dataSource.setPassword(MysqlConfig.PASSWORD);
dataSource.getConnection();
重启程序,发现就可以正常同时请求两个数据库了
三. 疑问
不知道是否是这个方法有这个限制还是flink内部导致的,希望知道的大佬可以指教指教
DriverManager.getConnection(URL, USERNAME, PASSWORD);
版权声明
本文为[zs_bigdata]所创,转载请带上原文链接,感谢
https://blog.csdn.net/m0_50670853/article/details/124328109
边栏推荐
- 错误: 找不到或无法加载主类
- L2-023 graph coloring problem (25 points) (graph traversal)
- Play with binary tree (25 points)
- After a circle, I sorted out this set of interview questions..
- LLVM之父Chris Lattner:编译器的黄金时代
- 虚拟线上展会-线上vr展馆实现24h沉浸式看展
- flask项目跨域拦截处理以及dbm数据库学习【包头文创网站开发】
- Latex mathematical formula
- Yangtao electronic STM32 Internet of things entry 30 step notes IV. engineering compilation and download
- Idea import commons-logging-1.2 Jar package
猜你喜欢

Summary of solid problems

Latex paper typesetting operation

L2-022 重排链表 (25 分)(map+结构体模拟)

GUI编程简介 swing

SYS_ CONNECT_ BY_ Path (column, 'char') combined with start with connect by prior

Star Trek's strong attack opens the dream linkage between metacosmic virtual reality

计算神经网络推理时间的正确方法

idea底栏打开services

DJ音乐管理软件Pioneer DJ rekordbox

PLC的点表(寄存器地址和点表定义)破解探测方案--方便工业互联网数据采集
随机推荐
扣缴义务人
ONEFLOW learning notes: from functor to opexprinter
mycat配置
关于数组复制问题
JSP page coding
OneFlow學習筆記:從Functor到OpExprInterpreter
应纳税所得额
请提前布局 Star Trek突破链游全新玩法,市场热度持续高涨
OneFlow学习笔记:从Functor到OpExprInterpreter
基于点云凸包的凹包获取方法
Single chip microcomputer nixie tube stopwatch
怎样读取Excel表格到数据库
Excle plus watermark
LaTeX论文排版操作
Notes on 30 steps of introduction to Internet of things of yangtao electronics STM32 III. Explanation of new cubeide project and setting
xctf刷题小记
Kubernetes如何使用harbor拉去私有镜像
rembg 分割mask
正点原子携手OneOS直播 OneOS系统教程全面上线
Use include in databinding