AI 助理
备案控制台
开发者社区 问答 正文

flink 聚合 job 重启问题

请教个问题，我通过程序拉取kafka消息后，注册为flink流表。然后执行sql: "select user_id, count(*)cnt from 流表"， 将结果写入到mysql 聚合表中（SINK组件为：flink1.11版本JdbcUpsertTableSink)。 但问题是，每次JOB重启后，之前mysql 聚合表结果会被清空。我设置了checkpoint和racksdbbackendstate.*来自志愿者整理的flink邮件归档

展开
收起
说了是一只鲳鱼 2021-12-07 10:11:22 1004 分享 版权

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

1 条回答
写回答
取消 提交回答
  • 小阿矿

    伪代码发下看看？看下jdbc sink的配置，是不是支持删除记录，更新的时候旧记录被删除了*来自志愿者整理的flink邮件归档

    2021-12-07 11:37:37
    赞同 展开评论
问答分类：
消息中间件 SQL 关系型数据库 MySQL Kafka 流计算 实时计算 Flink版 云消息队列 Kafka 版 云数据库 RDS MySQL 版
问答标签：
实时计算 Flink版重启 实时计算 Flink版job 实时计算 Flink版聚合 实时计算 Flink版job重启 实时计算 Flink版 job
问答地址：
开发者社区 > 数据库 > 问答
相关问答
Flink作业重启策略如何配置
62
1
0
在Flink CDC中，flink单机部署，重启flink客户端，之前正在运行的job可以自启动吗？
45
1
0
flink 累计重启如何排查问题？
56
0
0
Flink sql cdc 增量聚合 有文档吗？比如说基于CDC，算交易额的汇总
63
1
0
flink任务重启时 指定从6月5号某时开始执行，但数据看不到这段时间的是怎么回事？
55
1
0
在Flink CDC中重启任务时报了这个错，有一个表的binlog日志不存在，如何还能让任务正常跑？
97
1
0
Flink MySQL不支持定义Watermark如何进行窗口聚合
59
1
0
Flink下游业务系统能不能每5分钟聚合一次，不要实时去聚合查询？
62
1
0
Flink SQL使用mysql-cdc表，提示错误如下错误：我怎么样才能使用window聚合？
55
1
0
咨询一个Flink问题， 非开窗，非聚合的数据倾斜有什么优化思路？
67
1
0