各位好: 背景:Flink版本1.6.4,数据源为Kafka的主题A,B,消费者组相同 操作步骤:1.使用SavePoint取消任务。 2.修改代码将B去掉,只消费A主题。 3.从SavePoint启动任务,发现消费者组在B主题下的偏移量也回到了任务停止时的偏移量,之后偏移量马上变成了最新并继续消费。 想知道为什么修改代码不生效。
- Flink从SavePoint启动任务,修改的代码不生效 milan183sansiro
- ??????Flink??SavePoint?????????????????????????? wujunxi
- ??????Flink??SavePoint?????????????????????????? milan183sansiro
- Re: Flink从SavePoint启动任务,修改的代码不生效 Paul Lam
- 回复: Flink从SavePoint启动任务,修改的代码不生效 milan183sansiro