protected void clearInternal() {
final int partitionCount = getNodeEngine().getPartitionService().getPartitionCount();
final Integer completionId = registerCompletionLatch(partitionCount);
final OperationService operationService = getNodeEngine().getOperationService();
OperationFactory operationFactory = operationProvider.createClearOperationFactory(completionId);
try {
final Map<Integer, Object> results = operationService.invokeOnAllPartitions(getServiceName(), operationFactory);
int completionCount = 0;
for (Object result : results.values()) {
if (result != null && result instanceof CacheClearResponse) {