BUGFIX: Retry on conflict also in fulltext method

Author: gradinarufelix

Classes/Driver/Version6/IndexerDriver.php

@@ -28,6 +28,11 @@
  */
 class IndexerDriver extends AbstractIndexerDriver implements IndexerDriverInterface
 {
+    /**
+     * @Flow\InjectConfiguration(path="indexing.retryOnConflict")
+     * @var int
+     */
+    protected $retryOnConflict = 3;
 
     /**
      * {@inheritdoc}
@@ -43,7 +48,7 @@ public function document(string $indexName, NodeInterface $node, ElasticSearchDo
                     'update' => [
                         '_id' => $document->getId(),
                         '_index' => $indexName,
-                        'retry_on_conflict' => 3
+                        'retry_on_conflict' => $this->retryOnConflict ?: 3
                     ]
                 ],
                 // https://www.elastic.co/guide/en/elasticsearch/reference/5.0/docs-update.html
@@ -71,6 +76,7 @@ public function document(string $indexName, NodeInterface $node, ElasticSearchDo
                 'index' => [
                     '_id' => $document->getId(),
                     '_index' => $indexName,
+                    'retry_on_conflict' => $this->retryOnConflict ?: 3
                 ]
             ],
             $documentData
@@ -108,7 +114,8 @@ public function fulltext(NodeInterface $node, array $fulltextIndexOfNode, ?strin
         return [
             [
                 'update' => [
-                    '_id' => $closestFulltextNodeDocumentIdentifier
+                    '_id' => $closestFulltextNodeDocumentIdentifier,
+                    'retry_on_conflict' => $this->retryOnConflict ?: 3
                 ]
             ],
             // https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update.html

Configuration/Settings.yaml

@@ -4,6 +4,7 @@ Flowpack:
       command:
         useSubProcesses: true
       indexing:
+        retryOnConflict: 3
         batchSize:
           elements: 500
           octets: 40000000