You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2014/06/09 18:37:15 UTC
svn commit: r1601436 -
/manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
Author: kwright
Date: Mon Jun 9 16:37:14 2014
New Revision: 1601436
URL: http://svn.apache.org/r1601436
Log:
Fix query repeat issue, for real this time
Modified:
manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
Modified: manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java?rev=1601436&r1=1601435&r2=1601436&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java (original)
+++ manifoldcf/branches/CONNECTORS-946/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java Mon Jun 9 16:37:14 2014
@@ -2940,7 +2940,7 @@ public class JobManager implements IJobM
// Now we can tack the limit onto the query. Before this point, remainingDocuments would be crap
int limitValue = vList.getRemainingDocuments();
- query += database.constructOffsetLimitClause(0,limitValue,true);
+ String finalQuery = query + database.constructOffsetLimitClause(0,limitValue,true);
if (Logging.perf.isDebugEnabled())
{
@@ -2951,7 +2951,7 @@ public class JobManager implements IJobM
database.beginTransaction();
try
{
- IResultSet set = database.performQuery(query,list,null,null,-1,vList);
+ IResultSet set = database.performQuery(finalQuery,list,null,null,-1,vList);
if (Logging.perf.isDebugEnabled())
Logging.perf.debug(" Queuing "+Integer.toString(set.getRowCount())+" documents");