Skip to content

Commit 1dd8bd3

Browse files
kkondakaKrishna Kondaka
andauthored
Fix DLQ writer writing empty list (opensearch-project#2931)
Signed-off-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com> Co-authored-by: Krishna Kondaka <krishkdk@dev-dsk-krishkdk-2c-bd29c437.us-west-2.amazon.com>
1 parent b180634 commit 1dd8bd3

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

  • data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch

data-prepper-plugins/opensearch/src/main/java/org/opensearch/dataprepper/plugins/sink/opensearch/BulkRetryStrategy.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,6 +258,10 @@ private void handleFailures(final AccumulatingBulkRequest<BulkOperationWrapper,
258258

259259
private BulkOperationRequestResponse handleRetry(final AccumulatingBulkRequest request, final BulkResponse response, int retryCount) throws InterruptedException {
260260
final AccumulatingBulkRequest<BulkOperationWrapper, BulkRequest> bulkRequestForRetry = createBulkRequestForRetry(request, response);
261+
if (bulkRequestForRetry.getOperationsCount() == 0) {
262+
return null;
263+
}
264+
261265
final BulkResponse bulkResponse;
262266
try {
263267
bulkResponse = requestFunction.apply(bulkRequestForRetry);

0 commit comments

Comments
 (0)