Flink从SavePoint启动任务，修改的代码不生效
背景：Flink版本1.6.4，数据源为Kafka的主题A，B，消费者组相同 操作步骤：1.使用SavePoint取消任务。 2.修改代码将B去掉，只消费A主题。 3.从SavePoint启动任务，发现消费者组在B主题下的偏移量也回到了任务停止时的偏移量，之后偏移量马上变成了最新并继续消费。 想知道为什么修改代码不生效。 *来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
估计你是用同一个 Kafka Source 消费 A B 两个 Topic? 如果是，看起来像是 Kafka Connector 早期的一个问题。
作业停止的时候，Topic B 的 partition offset 被存储到 Savepoint 中，然后在恢复的时候，尽管代码中 Topic B 已经被移除，但它的 partition offset 还是被恢复了。
这个问题在后来的版本，估计是 1.8 或 1.9，被修复了。*来自志愿者整理的flink邮件归档
2021-12-07 16:22:05赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
