opensearch-project / opensearch-project/data-prepper

[BUG] Issue with dynamoDb export where S3 connections are dropping

Open
#5,461 0 comments 1 reaction 1 assignee View on GitHub

@sb2k16 is already working on this.

Since Feb 25, 2025.

bug
Dominant language
Java
Stars
374
Forks
354
Avg merge
3d 18h
Merged PRs (30d)
8

Description

Describe the bug
For dynamoDb pipeline with export enabled, it looks the S3 connection during the export process is dropping resulting in reprocessing of the entire file. This results in the pipeline not being able to complete the export process and start the streaming ingestion.

This is the error we can see:

ERROR org.opensearch.dataprepper.plugins.source.dynamodb.export.DataFileScheduler - There was an exception while processing an S3 data file: java.util.concurrent.CompletionException: java.lang.RuntimeException: Loading of s3://bucket/export/AWSDynamoDB/7zzb546dhkx2v6jq.ion.gz completed with Exception: Read timed out

Currently, the code calls getObject API that returns a stream. Instead, we can use the range on the getObject API to retrieve chunks of the S3 object till there are chunks/partitions available.
This behavior becomes more frequent when the s3 bucket is in a different region than the region from where data prepper is configured to run.

Expected behavior
The connections to S3 from the pipeline should be reliable.

Contributor guide

Open the contributing guide

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.