KAFKA-10199: Commit the restoration progress within StateUpdater (#12279)
During restoring, we should always commit a.k.a. write checkpoint file regardless of EOS or ALOS, since if there's a failure we would just over-restore them upon recovery so no EOS violations happened. Also when we complete restore or remove task, we should enforce a checkpoint as well; for failing cases though, we should not write a new one. Reviewers: Bruno Cadonna <cadonna@apache.org>
显示
- streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java 2 个添加, 2 个删除...pache/kafka/streams/processor/internals/AbstractTask.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java 33 个添加, 3 个删除...afka/streams/processor/internals/DefaultStateUpdater.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java 1 个添加, 1 个删除...apache/kafka/streams/processor/internals/StandbyTask.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java 4 个添加, 4 个删除.../apache/kafka/streams/processor/internals/StreamTask.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java 6 个添加, 0 个删除...va/org/apache/kafka/streams/processor/internals/Task.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdaterTest.java 94 个添加, 7 个删除.../streams/processor/internals/DefaultStateUpdaterTest.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java 41 个添加, 0 个删除...he/kafka/streams/processor/internals/StandbyTaskTest.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java 16 个添加, 0 个删除...che/kafka/streams/processor/internals/StreamTaskTest.java
加载中
想要评论请 注册 或 登录