开发者社区大数据与机器学习实时计算 Flink 正文

flink sql从pg同步数据，在flink sql创建表，然后insert，重复操作几遍就报这个

flink sql从pg同步数据，在flink sql创建表，然后insert，重复操作几遍就报这个错，表都是有主键的，哪位大佬知道原因吗？

展开

收起

爱喝咖啡嘿 2023-01-03 15:38:33 321 版权

1 条回答

写回答

取消提交回答

清风拂袖

错误原因：

此错误表明 Flink 作业提交失败，因为恢复模式被禁用。

解决办法：

要解决此问题，需要在提交作业时启用恢复模式。可以在 --execution-mode 参数中指定恢复模式，如下所示：

flink run -e yarn --execution-mode recovery

2024-02-27 17:46:18

赞同展开评论

问答分类：

SQL 关系型数据库流计算实时计算 Flink版

问答标签：

SQL数据实时计算 Flink版数据实时计算 Flink版同步实时计算 Flink版pg 实时计算 Flink版sql同步数据

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

flink 1.18.1 同步oracle 19c 到pg 15，job执行以后一直无法实现资料同步

138

我们在用flink sql 做实时指标计算时，insert into语句能否动态修改？

159

现在flink支持with insert into语句吗？

在Flink CDC中，insert into 任务提交到flink上去了？

103

Flink的insert方式是要提前建表而且不会同步表结构变更的么？

flink cdc 写代码的方式接收数据-map操作-sink到表是导入那个Maven依赖啊？

Flink cdc 任务启动后，发现PG数据库中的这个进程一直是lock状态,如何解决？

131

在Flink CDC中通过配置文件，字段数据类型tinyint映射成boolean,如何操作？

380

Flink有操作过restapi 上传jar和开启job的吗？

DataWorks一个sql脚本任务里面有多个select insert语句执行的时候是并行的吗？

117

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

关于sql工具的小理解

查寻MySQL或SQL Server的连接数，并配置超时时间和最大连接量

4-MongoDB索引知识

深入理解MySQL的MVCC（多版本并发控制）实现原理

MySQL中的int(10)、char(10)与varchar(10)的类型和区别

flink sql从pg同步数据，在flink sql创建表，然后insert，重复操作几遍就报这个

实时计算 Flink

相关文章

热门讨论

热门文章