代码flinksql:
报错内容:
有没有遇到这种问题的朋友
Caused by: org.postgresql.util.PSQLException: ERROR: modification of distribution columns in OnConflictUpdate is not supported
一个flinkcdc到postgresql的问题
报错内容:
有没有遇到这种问题的朋友
Caused by: org.postgresql.util.PSQLException: ERROR: modification of distribution columns in OnConflictUpdate is not supported
- 写回答
- 好问题 0 提建议
- 关注问题
分享- 邀请回答
-
2条回答 默认 最新
- 2023-09-08 23:27SeniorCollector的博客 wal_level必须更改，其它参数选着性更改，如果同步表数量超过10张建议修改为合适的值。2.新建用户并且给用户复制流权限（例如在navicat中操作）1.更改配置文件postgresql.conf。一、准备（PG版本为9.6.24）
- 2022-08-24 17:35BigDataMK的博客 flinkCDC数据同步之 postgresql to starrocks
- 2023-07-20 15:24杨林伟的博客 flink postgresql cdc实时同步，含pg安装配置等
- 2023-04-07 20:424. **定义数据接收方**：将处理后的数据流发送到目标系统，如另一个数据库、消息队列或实时展示平台。 5. **监控与故障恢复**：通过Flink的检查点和状态管理，确保即使在故障后也能从最后一个已知状态恢复，保持数据...
- 2022-10-26 10:30FlinkCDC（Change Data Capture）是Flink的一个扩展模块，用于捕获数据库的变化事件，例如MySQL、PostgreSQL等。它通过监听数据库的日志，实时获取到数据库的插入、更新和删除操作，将这些变更事件转化为可处理的...
- 2024-10-18 19:12数据与算法架构提升之路的博客 PostgreSQL通过Replication Slot和Logical Decoding实现CDC，捕获数据变更并通过Debezium等工具发送到消息队列。WAL日志记录数据库操作，而Debezium支持多种部署方式，如Kafka Connect和嵌入式引擎，以实现数据流...
- 2024-09-19 00:40Lansonli的博客 Flink CDC 基于数据库日志的 Change Data Caputre 技术，实现了全量和增量的一体化读取能力，并借助 Flink 优秀的管道能力和丰富的上下游生态，支持捕获多种数据库的变更，并将这些变更实时同步到下游存储。...
- 2021-11-03 23:38它允许Flink直接从MySQL、PostgreSQL等数据库读取全量数据和增量变更数据，形成一个持续的数据流。Flink-CDC的优势在于其低延迟和高吞吐量，使得实时数仓的构建更加高效。 2. Flink CDC案例实操 2.1 DataStream应用...
- 2024-03-24 18:36ynzhangyao的博客 将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就不说了，相信你已经有了数据库了。
- 2023-12-16 02:17AI何哥的博客 一个数据源分发给多个下游系统；面向数据仓库 / 数据湖的 ETL 数据集成，是非常重要的数据源。离线调度查询作业，批处理。把一张表同步到其他系统，每次通过查询去获取表中最新的数据；无法保障数据一致性，查的过程...
- 没有解决我的问题, 去提问
问题事件
创建了问题
12月24日