You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by jm...@apache.org on 2021/12/15 20:26:54 UTC
svn commit: r1896007 - /manifoldcf/trunk/connectors/solr/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/solr/SolrIngesterConnector.java
Author: jmssiera
Date: Wed Dec 15 20:26:54 2021
New Revision: 1896007
URL: http://svn.apache.org/viewvc?rev=1896007&view=rev
Log:
Fix CONNECTORS-1686 Compile issue
Modified:
manifoldcf/trunk/connectors/solr/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/solr/SolrIngesterConnector.java
Modified: manifoldcf/trunk/connectors/solr/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/solr/SolrIngesterConnector.java
URL: http://svn.apache.org/viewvc/manifoldcf/trunk/connectors/solr/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/solr/SolrIngesterConnector.java?rev=1896007&r1=1896006&r2=1896007&view=diff
==============================================================================
--- manifoldcf/trunk/connectors/solr/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/solr/SolrIngesterConnector.java (original)
+++ manifoldcf/trunk/connectors/solr/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/solr/SolrIngesterConnector.java Wed Dec 15 20:26:54 2021
@@ -552,21 +552,21 @@ public class SolrIngesterConnector exten
query.setFields(idFieldName, versionField);
query.addFilterQuery(idFieldName + ":(" + documentIdentifiersString + ")");
- String nextCursorMark = cursorMark;
- try {
- nextCursorMark = response.getNextCursorMark();
- } catch (Exception e) {
- // Something wrong with the response, break
- Logging.connectors.warn("SolrIngester: the type of the reponse getnextcursormark is not recognized as a String");
- break;
- }
+ String cursorMark = CursorMarkParams.CURSOR_MARK_START;
boolean done = false;
while (!done) {
query.set(CursorMarkParams.CURSOR_MARK_PARAM, cursorMark);
QueryResponse response;
response = httpSolrClient.query(collection, query);
- final String nextCursorMark = response.getNextCursorMark();
+ String nextCursorMark = cursorMark;
+ try {
+ nextCursorMark = response.getNextCursorMark();
+ } catch (Exception e) {
+ // Something wrong with the response, break
+ Logging.connectors.warn("SolrIngester: the type of the reponse getnextcursormark is not recognized as a String");
+ break;
+ }
final SolrDocumentList documents = response.getResults();
for (final SolrDocument document : documents) {
existingIds.put((String) document.getFieldValue(idFieldName), String.valueOf(document.getFieldValue(versionField)));