return data.isEmpty() ? null : new CounterMigrationOperation(data);
}
@Override
public void commitMigration(PartitionMigrationEvent event) {
if (event.getMigrationEndpoint() == MigrationEndpoint.SOURCE) {
<BUG>Container container = containers[event.getPartitionId()];
container.clear();
}</BUG>
}
@Override

return data.isEmpty() ? null : new CounterMigrationOperation(data);
}
@Override
public void commitMigration(PartitionMigrationEvent event) {
if (event.getMigrationEndpoint() == MigrationEndpoint.SOURCE) {
int newReplicaIndex = event.getNewReplicaIndex();
if (newReplicaIndex == -1 || newReplicaIndex > 1) {
clearPartitionReplica(event.getPartitionId());
}
}
}
@Override
