jdbc sink无法插入数据怎么办?
我在使用flink1.12,现在有一个job,数据最后需要同时进入Kafka和数据库,所以在最后一步操作里加了side output,代码如下 .process(new ProcessFunction() { @Override public void proce...
有处理过flink sink phoenix ?我现在用jdbc sink 获取连接时#Flink
有处理过flink sink phoenix ?我现在用jdbc sink 获取连接时有一个info的异常日志,然后数据不发插入进phoenix #Flink
之前 flink1.6.2的jdbc好像有加定时sink的功能? #Flink
之前 flink1.6.2的jdbc好像有加定时sink的功能? #Flink
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。