关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
m0_47107655
2022-12-24 11:33
采纳率: 0%
浏览 65
首页
大数据
一个flinkcdc到postgresql的问题
postgresql
mysql
flink
代码flinksql:
报错内容:
有没有遇到这种问题的朋友
Caused by: org.postgresql.util.PSQLException: ERROR: modification of distribution columns in OnConflictUpdate is not supported
收起
写回答
好问题
0
提建议
关注问题
微信扫一扫
点击复制链接
分享
邀请回答
编辑
收藏
删除
结题
收藏
举报
2
条回答
默认
最新
关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
三千烦恼丝xzh
2022-12-29 17:16
关注
你是否正确的建立上下游数据结构,比如sink的postgresql表是否正确建立主键约束
本回答被题主选为最佳回答
, 对您是否有帮助呢?
本回答被专家选为最佳回答
, 对您是否有帮助呢?
本回答被题主和专家选为最佳回答
, 对您是否有帮助呢?
解决
无用
评论
打赏
微信扫一扫
点击复制链接
分享
举报
评论
按下Enter换行,Ctrl+Enter发表内容
查看更多回答(1条)
向“C知道”追问
报告相同问题?
提交
关注问题
Flink
CDC
实时读取
PostgreSQL
2023-09-08 23:27
SeniorCollector的博客
wal_level必须更改,其它参数选着性更改,如果同步表数量超过10张建议修改为合适的值。2.新建用户并且给用户复制流权限(例如在navicat中操作)1.更改配置文件
postgresql
.conf。一、准备(PG版本为9.6.24)
flink
CDC
数据同步之
postgresql
to starrocks
2022-08-24 17:35
BigDataMK的博客
flink
CDC
数据同步之
postgresql
to starrocks
flink
postgresql
cdc
实时同步(含pg安装配置等)
2023-07-20 15:24
杨林伟的博客
flink
postgresql
cdc
实时同步,含pg安装配置等
flink
cdc
postgresql
2023-04-07 20:42
4. **定义数据接收方**:将处理后的数据流发送到目标系统,如另
一个
数据库、消息队列或实时展示平台。 5. **监控与故障恢复**:通过
Flink
的检查点和状态管理,确保即使在故障后也能从最后
一个
已知状态恢复,保持数据...
基于
Flink
+
Flink
CDC
+
Flink
SQL+Clickhouse构建实时数据仓库课程
2022-10-26 10:30
Flink
CDC
(Change Data Capture)是
Flink
的
一个
扩展模块,用于捕获数据库的变化事件,例如MySQL、
PostgreSQL
等。它通过监听数据库的日志,实时获取到数据库的插入、更新和删除操作,将这些变更事件转化为可处理的...
Flink
PostgreSQL
CDC
源码解读:深入理解数据流同步
2024-10-18 19:12
数据与算法架构提升之路的博客
PostgreSQL
通过Replication Slot和Logical Decoding实现
CDC
,捕获数据变更并通过Debezium等工具发送到消息队列。WAL日志记录数据库操作,而Debezium支持多种部署方式,如Kafka Connect和嵌入式引擎,以实现数据流...
大数据
Flink
(一百二十一):
Flink
CDC
基本介绍
2024-09-19 00:40
Lansonli的博客
Flink
CDC
基于数据库日志的 Change Data Caputre 技术,实现了全量和增量的一体化读取能力,并借助
Flink
优秀的管道能力和丰富的上下游生态,支持捕获多种数据库的变更,并将这些变更实时同步到下游存储。...
实时数仓_
Flink
CDC
.pdf
2021-11-03 23:38
它允许
Flink
直接从MySQL、
PostgreSQL
等数据库读取全量数据和增量变更数据,形成
一个
持续的数据流。
Flink
-
CDC
的优势在于其低延迟和高吞吐量,使得实时数仓的构建更加高效。 2.
Flink
CDC
案例实操 2.1 DataStream应用...
Flink
CDC
1.18.1 Oracle 数据同步到
postgresql
2024-03-24 18:36
ynzhangyao的博客
将
flink
-sql-connector-oracle-
cdc
-3.0.1.jar复制到
flink
-1.18.1/lib目录中。6、下载
flink
-connector-jdbc-3.1.1-1.17.jar,
postgresql
-42.7.3.jar。7、安装
postgresql
就不说了,相信你已经有了数据库了。
大数据
技术14:
Flink
CDC
数据变更捕获
2023-12-16 02:17
AI何哥的博客
一个
数据源分发给多个下游系统;面向数据仓库 / 数据湖的 ETL 数据集成,是非常重要的数据源。离线调度查询作业,批处理。把一张表同步到其他系统,每次通过查询去获取表中最新的数据;无法保障数据一致性,查的过程...
没有解决我的问题,
去提问
向专家提问
向AI提问
付费问答(悬赏)服务下线公告
◇ 用户帮助中心
◇ 新手如何提问
◇ 奖惩公告
问题事件
关注
码龄
粉丝数
原力等级 --
被采纳
被点赞
采纳率
创建了问题
12月24日