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

JDBC数据库开发入门

15 课时 |
1906 人已学 |
免费

JDBC数据库开发进阶

22 课时 |
1185 人已学 |
免费
开发者课程背景图

之前 flink1.6.2的jdbc好像有加定时sink的功能? #Flink

之前 flink1.6.2的jdbc好像有加定时sink的功能? #Flink

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。