Flink CDC MySQL 同步数据至 MongoDB，一直报错 Could not find any factory for identifier 'mongodb' that implements ，请问我哪里姿势不对呢？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

This topic created in 639 days ago, the information mentioned may be changed or developed.

这个是安装脚本
version: '3'
services:
jobmanager:
image: flink:1.16.1-java8
expose:
- "6123"
ports:
- "8081:8081"
command: jobmanager
volumes:
- ./flink-checkpoints:/opt/flink/flink-checkpoints
- ./flink-savepoints:/opt/flink/flink-savepoints
- ./logs/job:/opt/flink/log
- ./runjob:/opt/flink/usrlib
environment:
JOB_MANAGER_RPC_ADDRESS: jobmanager
TZ: Asia/Shanghai
taskmanager:
image: flink:1.16.1-java8
expose:
- "6121"
- "6122"
depends_on:
- jobmanager
command: taskmanager
volumes:
- ./flink/flink-checkpoints:/opt/flink/flink-checkpoints
- ./flink/flink-savepoints:/opt/flink/flink-savepoints
- ./flink/log/mngr:/opt/flink/log
- ./flink/runjob:/opt/flink/usrlib
links:
- "jobmanager:jobmanager"
environment:
JOB_MANAGER_RPC_ADDRESS: jobmanager
TZ: Asia/Shanghai

flink

CDC

MongoDB

2 replies • 2024-07-30 16:36:49 +08:00

zhenjiachen

Jul 30, 2024

没有导入 cdc 的包吧

hero1874

Jul 30, 2024

缺少包看一下对应的包是否存在。