diff --git a/contrib/dataimporthandler/src/main/java/org/apache/solr/handler/dataimport/DocBuilder.java b/contrib/dataimporthandler/src/main/java/org/apache/solr/handler/dataimport/DocBuilder.java index 77177080d7e..02f6bf44bdc 100644 --- a/contrib/dataimporthandler/src/main/java/org/apache/solr/handler/dataimport/DocBuilder.java +++ b/contrib/dataimporthandler/src/main/java/org/apache/solr/handler/dataimport/DocBuilder.java @@ -237,8 +237,7 @@ public class DocBuilder { addStatusMessage("Identifying Delta"); LOG.info("Starting delta collection."); Set> deletedKeys = new HashSet>(); - Set> allPks = collectDelta(root, null, resolver, - dataImporter, deletedKeys); + Set> allPks = collectDelta(root, null, resolver, deletedKeys); if (stop.get()) return; addStatusMessage("Deltas Obtained"); @@ -568,7 +567,7 @@ public class DocBuilder { @SuppressWarnings("unchecked") public Set> collectDelta(DataConfig.Entity entity, DataConfig.Entity parentEntity, VariableResolverImpl resolver, - DataImporter dataImporter, Set> deletedRows) { + Set> deletedRows) { //someone called abort if (stop.get()) return new HashSet(); @@ -579,8 +578,7 @@ public class DocBuilder { for (DataConfig.Entity entity1 : entity.entities) { //this ensures that we start from the leaf nodes - myModifiedPks.addAll(collectDelta(entity1, entity, resolver, dataImporter, - deletedRows)); + myModifiedPks.addAll(collectDelta(entity1, entity, resolver, deletedRows)); //someone called abort if (stop.get()) return new HashSet();