Clean up lastWrittenOffset

rayokota · Mar 24, 2019 · 991ea20 · 991ea20
1 parent b9bde67
commit 991ea20
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kafka-graphs-core/src/main/java/io/kgraph/pregel/PregelComputation.java b/kafka-graphs-core/src/main/java/io/kgraph/pregel/PregelComputation.java
@@ -521,6 +521,7 @@ && isTopicSynced(internalConsumer, edgesGroupedBySourceTopic, 0, graphOffsets::g
                                 activeVertices.remove(previousStep);
                                 forwardedVertices.remove(previousStep);
                                 didPreSuperstep.remove(previousStep);
+                                lastWrittenOffsets.remove(previousStep);
                                 aggregators.remove(previousStep);
                                 previousAggregates.remove(previousStep);
                                 localworkSetStore.delete(previousStep);