备案控制台
探索云世界
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请问基于1.7的flink，sink到mysql如何实现精确一次端到端呢？

请问基于1.7的flink，sink到mysql如何实现精确一次端到端呢？ 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

展开
收起
黄一刀 2019-12-27 18:00:34 1781 0
2 条回答
写回答
取消 提交回答
  • 海贼王fans
    个人对建模比较关注

    flink更新在一次cp内的，无需事务控制。

    2020-03-25 16:57:12
    赞同 展开评论 打赏
  • 黄二刀

    总的来说就是，mysql事物为读已提交，sink正常写mysql 不提交，做 checkpoint 的时候再提交，具体，可以参考下 flinkkafkaproducer

    2019-12-27 18:01:05
    赞同 展开评论 打赏
问答分类：
关系型数据库 MySQL 开发者 流计算 实时计算 Flink版 云数据库 RDS MySQL 版
问答标签：
flink云数据库 RDS MySQL 版 云数据库 RDS MySQL 版flink 实时计算 Flink版sink mysql sink云数据库 RDS MySQL 版 实时计算 Flink版端到端
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关产品：
实时计算 Flink版

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答
实时计算 Flink版
Flink CDC3.0什么时候支持sink到mysql呀？
57
0
0
请问下，官方有提供flink Sink websocket的connector吗？
15
0
0
Flink多并发sink 更新 redis 值，如何保证数据能按事件时间来更新数据？一致性如何保证？
67
5
0
flink cdc pipeline配置文件那种sink支持MySQL吗？
38
1
0
Flink CDC里pipeline方式是自动进行端到端的表结构变更，SQL方式就不支持了吧？
98
4
0
Flink CDC里MySQL CDC Pipeline 连接器 支持配置sink到mysql吗？
47
1
0
flink 端到端延迟以及flinkcdc 同步mysql时的延迟存在突刺，怎么寻找排查原因？
47
0
0
flink cdc不支持sink到mysql嘛？
31
3
0
Hologres中flink sink hologres要设置啥参数吗？
38
3
0
Flink CDC自定义的sink端连接mysql久了报错，有人知道怎么解决吗？
19
0
0
大数据与机器学习

实时计算 Flink

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

我要提问

相关产品

  • 实时计算 Flink版
    文档详情 产品详情

    • 热门讨论

    热门文章

  • flinkcdc3.0整库同步mysql的数据到starrocks中全量能过去增量过不去怎么排查？
    290
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
    1551
  • Flink-CDC 文档网站地址是什么？
    18086
  • flink1.15启动后无法访问webui的问题有人遇到过吗
    9638
  • Caused by: org.apache.kafka.common.errors.TimeoutE
    2107
  • 使用Flink CDC，生产环境要申请的服务器如何评估
    684
  • Flink1.17为什么需要JDK 11呢？JDK8我试了也能运行
    600
  • "flink-cdc-connector-mysql，这个报错怎么解决的？
    1167
  • flink 1.18必须配套JDK11吗 1.8是不是不行了呢？
    768
  • 现在flink消费kafka限速是怎么做的?
    287
    • 展开全部
  • 数据仓库介绍与实时数仓案例
    40025
  • 权威详解 | 阿里新一代实时计算引擎 Blink，每秒支持数十亿次计算
    22046
  • OPPO数据中台之基石：基于Flink SQL构建实数据仓库
    20797
  • 通过Flink实时构建搜索引擎的索引
    16783
  • Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示
    21441
  • 阿里云实时计算产品案例&解决方案汇总
    24278
  • 流计算精品翻译: The Dataflow Model
    18516
  • Flink SQL 功能解密系列 —— 流式 TopN 挑战与实现
    15874
  • Apache Flink 的迁移之路，2 年处理效果提升 5 倍
    9541
  • 基于实时计算（Flink）打造一个简单的实时推荐系统
    13826
    • 展开全部

    相关课程

    更多
  • MySQL企业常见架构与调优经验分享
    12391
    7
    去学习
  • 云数据库MySQL版快速上手教程
    19904
    13
    去学习
  • 阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
    112
    5
    去学习
  • MySQL实战进阶
    4063
    7
    去学习
  • 数据库及SQL/MySQL基础
    5459
    22
    去学习
  • 云数据库MySQL快速入门
    2548
    10
    去学习

    • 相关文章

  • 前端xss攻击——规避innerHtml过滤标签节点及属性
  • 构建高效Android应用：Kotlin协程的实践之路
  • 计算巢开发者活动：(一)计算巢产品介绍
  • 构建高效Android应用：Kotlin的协程与Flow
  • 深入理解PHP的命名空间和自动加载机制

    • 相关电子书

    更多
    • 搭建电商项目架构连接MySQL 立即下载
    搭建4层电商项目架构，实战连接MySQL 立即下载
    PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

    相关实验场景

    更多
  • 极致弹性的PolarDB Serverless确保数据业务持续在线
    228
    1.0小时
    去实验
  • 云端MySQL的安装及应用
    1740
    2.0小时
    去实验
  • 体验PolarDB MySQL多主集群
    167
    1.0小时
    去实验
  • 基于ECS+RDS的在线留言系统
    1362
    2.0小时
    去实验
  • 如何通过RDS MySQL数据库内网访问
    317
    1.0小时
    去实验
  • RDS MySQL Serverless资源与负载自适应
    4303
    1.0小时
    去实验

    • 相关镜像

  • mysql
  • mariadb
  • postgresql