in crossdc-consumer/src/main/java/org/apache/solr/crossdc/messageprocessor/SolrMessageProcessor.java [245:261]
private void prepareIfUpdateRequest(SolrRequest request) {
if (request instanceof UpdateRequest) {
// Remove versions from add requests
UpdateRequest updateRequest = (UpdateRequest) request;
List<SolrInputDocument> documents = updateRequest.getDocuments();
if (log.isTraceEnabled()) {
log.trace("update request docs={} deletebyid={} deletebyquery={}", documents, updateRequest.getDeleteById(), updateRequest.getDeleteQuery());
}
if (documents != null) {
for (SolrInputDocument doc : documents) {
sanitizeDocument(doc);
}
}
removeVersionFromDeleteByIds(updateRequest);
}
}