diff --git a/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/AclTracker.java b/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/AclTracker.java index 9b50db4f7..32404ed22 100644 --- a/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/AclTracker.java +++ b/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/AclTracker.java @@ -636,7 +636,6 @@ public class AclTracker extends AbstractTracker AclChangeSets aclChangeSets; BoundedDeque changeSetsFound = new BoundedDeque(100); HashSet changeSetsIndexed = new LinkedHashSet(); - TrackerState state = super.getTrackerState(); long totalAclCount = 0; int aclCount = 0; @@ -647,11 +646,7 @@ public class AclTracker extends AbstractTracker getWriteLock().acquire(); //System.out.println("############# AclTracker acquire lock ################"); - if(state == null) - { - // A rollback occurred. Break and let the next tracker get the state from the index. - break; - } + TrackerState state = getTrackerState(); Long fromCommitTime = getChangeSetFromCommitTime(changeSetsFound, state.getLastGoodChangeSetCommitTimeInIndex()); aclChangeSets = getSomeAclChangeSets(changeSetsFound, fromCommitTime, TIME_STEP_1_HR_IN_MS, 2000, diff --git a/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/MetadataTracker.java b/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/MetadataTracker.java index 305408062..3dc6ec74b 100644 --- a/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/MetadataTracker.java +++ b/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/MetadataTracker.java @@ -583,7 +583,6 @@ public class MetadataTracker extends AbstractTracker implements Tracker Transactions transactions; BoundedDeque txnsFound = new BoundedDeque(100); HashSet txsIndexed = new LinkedHashSet<>(); - TrackerState state = this.getTrackerState(); long totalUpdatedDocs = 0; int docCount = 0; @@ -594,11 +593,7 @@ public class MetadataTracker extends AbstractTracker implements Tracker getWriteLock().acquire(); //System.out.println("######## Metadata Tracket Acquiring Write Lock ########"); - if(state == null) - { - //A rollback occurred in the CommitTracker. Break the loop and let the next tracker create the next state. - break; - } + TrackerState state = getTrackerState(); //System.out.println("######## Do Track Transactions ########:"+docCount);