log.info("{} - removing partition: {}", id, partition);
this.partitions.remove(partition);
Map<String, AdderResult> state = recordHandler.removePartition(partition);
log.info("{} - removing partition: {}", id, partition);
this.partitions.remove(partition);
Map<String, AdderResult> state = recordHandler.removePartition(partition);
}
Map<String, List<AdderResult>> results = adderResults.removePartition(partition);
stateRepository.save(new StateDocument(partition, state, results));
}
Map<String, List<AdderResult>> results = adderResults.removePartition(partition);
stateRepository.save(new StateDocument(partition, state, results));