Skip to content

Commit 806fe5b

Browse files
committed
TASK: Exchange MalformedBulkRequestError to plain error log message
1 parent 1eeece6 commit 806fe5b

2 files changed

Lines changed: 1 addition & 73 deletions

File tree

Classes/Indexer/Error/MalformedBulkRequestError.php

Lines changed: 0 additions & 71 deletions
This file was deleted.

Classes/Indexer/NodeIndexer.php

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\ElasticSearchClient;
2424
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Exception;
2525
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Indexer\Error\BulkIndexingError;
26-
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Indexer\Error\MalformedBulkRequestError;
2726
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Service\DimensionsService;
2827
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Service\ErrorHandlingService;
2928
use Flowpack\ElasticSearch\ContentRepositoryAdaptor\Service\IndexNameService;
@@ -449,7 +448,7 @@ public function flush(): void
449448

450449
foreach ($bulkRequestPart->getRequest() as $bulkRequestItem) {
451450
if ($bulkRequestItem === null) {
452-
$this->errorHandlingService->log(new MalformedBulkRequestError('Indexing Error: Bulk request item could not be encoded as JSON - ' . json_last_error_msg(), $bulkRequestItem));
451+
$this->logger->error('Indexing Error: A bulk request item could not be encoded as JSON', LogEnvironment::fromMethodName(__METHOD__));
453452
continue 2;
454453
}
455454
$payload[$hash][] = $bulkRequestItem;

0 commit comments

Comments
 (0)