mirror of
https://github.com/Alfresco/SearchServices.git
synced 2025-10-01 14:41:19 +00:00
Merge pull request #1070 from Alfresco/fix/SEARCH-2568_OOMLargeAncestorList
SEARCH-2568: Skip indexing transactions from a given Transaction Id.
This commit is contained in:
@@ -181,6 +181,13 @@ public class MetadataTracker extends ActivatableTracker
|
|||||||
minTxnIdRange = new Pair<>(Long.valueOf(minTxninitialRangeString[0]), Long.valueOf(minTxninitialRangeString[1]));
|
minTxnIdRange = new Pair<>(Long.valueOf(minTxninitialRangeString[0]), Long.valueOf(minTxninitialRangeString[1]));
|
||||||
forkJoinPool = new ForkJoinPool(matadataTrackerParallelism);
|
forkJoinPool = new ForkJoinPool(matadataTrackerParallelism);
|
||||||
|
|
||||||
|
if (p.getProperty("solr.initial.transaction.id") != null)
|
||||||
|
{
|
||||||
|
Long initialTransactionId = Long.parseLong(p.getProperty("solr.initial.transaction.id"));
|
||||||
|
minTxnIdRange = new Pair<>(initialTransactionId, initialTransactionId + 2000l);
|
||||||
|
LOGGER.info("Start indexing from transaction {}, previous transactions will be ignored.", initialTransactionId);
|
||||||
|
}
|
||||||
|
|
||||||
RUN_LOCK_BY_CORE.put(coreName, new Semaphore(1, true));
|
RUN_LOCK_BY_CORE.put(coreName, new Semaphore(1, true));
|
||||||
WRITE_LOCK_BY_CORE.put(coreName, new Semaphore(1, true));
|
WRITE_LOCK_BY_CORE.put(coreName, new Semaphore(1, true));
|
||||||
|
|
||||||
|
@@ -225,6 +225,12 @@ solr.request.content.compress=false
|
|||||||
#
|
#
|
||||||
solr.initial.transaction.range=0-2000
|
solr.initial.transaction.range=0-2000
|
||||||
|
|
||||||
|
#
|
||||||
|
# Start indexing from a given Transaction Id, skipping the previous ones
|
||||||
|
# WARNING: This is a DEVELOPMENT feature and it must not be used in PROD environments
|
||||||
|
#
|
||||||
|
#solr.initial.transaction.id=
|
||||||
|
|
||||||
#
|
#
|
||||||
# Limit the maximum text size of transformed content sent to the index - in bytes
|
# Limit the maximum text size of transformed content sent to the index - in bytes
|
||||||
#
|
#
|
||||||
|
Reference in New Issue
Block a user