diff --git a/data-prepper-plugins/dynamodb-source/src/main/java/org/opensearch/dataprepper/plugins/source/dynamodb/export/DataFileScheduler.java b/data-prepper-plugins/dynamodb-source/src/main/java/org/opensearch/dataprepper/plugins/source/dynamodb/export/DataFileScheduler.java index 097108324f..4ffb1df9ee 100644 --- a/data-prepper-plugins/dynamodb-source/src/main/java/org/opensearch/dataprepper/plugins/source/dynamodb/export/DataFileScheduler.java +++ b/data-prepper-plugins/dynamodb-source/src/main/java/org/opensearch/dataprepper/plugins/source/dynamodb/export/DataFileScheduler.java @@ -39,7 +39,7 @@ public class DataFileScheduler implements Runnable { /** * Maximum concurrent data loader per node */ - private static final int MAX_JOB_COUNT = 3; + private static final int MAX_JOB_COUNT = 1; /** * Default interval to acquire a lease from coordination store