sink oracle端的时候偶尔有几个任务出现 kafka接收到数据有 Initializing C3P0 pool

DTStack / flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法

Apache License 2.0

2.02k stars 926 forks source link

Open tonyC2016 opened 3 years ago

tonyC2016 commented 3 years ago

数据流转 kafka -flink-oracle yarn-per 模式。能再yarn上运行起来，但在kakfa接收到数据之后就一直卡在Initializing C3P0 pool

tonyC2016 commented 3 years ago

没有明显异常的错误信息，初步排查了数据库链接充裕的，然后内存CPU都够

tonyC2016 commented 3 years ago

tm 节点和oracle通信没有问题

zjfplayer commented 3 years ago

就是最终没算出结果如果红框内rowList没有数据，那就是where之前都没出数据，如果有数据，就是where去匹配的时候没出数据