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

Flink CDC 里flink是docker部署的,目前想把postgre同步到es,报错咋办?

Flink CDC 里我的flink是docker部署的,我目前想把postgre同步到es,但是报kafka的异常?用的是默认的配置,没有单独指定配置。add4481ebb694dcd59513275a7792a48.pngjobmanager:
restart: always
image: flink:1.16.0-scala_2.12-java11
container_name: jobmanager
ports:

  - "8087:8081"
command: jobmanager
environment:
  - |
    FLINK_PROPERTIES=
    jobmanager.rpc.address: jobmanager
    jobmanager.memory.process.size: 1024m
volumes:
  - ./build/settings/:/settings
  - ./build/data/:/data
networks:
  - smart-net

taskmanager:
restart: always
image: flink:1.16.0-scala_2.12-java11
container_name: taskmanager
depends_on:

  - jobmanager
command: taskmanager
scale: 1
environment:
  - |
    FLINK_PROPERTIES=
    jobmanager.rpc.address: jobmanager
    taskmanager.numberOfTaskSlots: 6
    taskmanager.memory.process.size: 1024m
    taskmanager.memory.jvm-overhead.min: 200m

volumes:
  - ./build/settings/:/settings
  - ./build/data/:/data
networks:
  - smart-net这是flink docker compose 的相关配置![ee31bda69971be29e6d4699c49470695.png](https://ucc.alicdn.com/pic/developer-ecology/cckkirpdqa7sk_84a0708a3a9447b384e2c13b7d263cf1.png)sql client。

展开
收起
小小鹿鹿鹿 2024-03-11 16:09:15 20 0
1 条回答
写回答
取消 提交回答

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载
    http://www.vxiaotou.com