diff --git a/data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/plugins/InMemorySource.java b/data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/plugins/InMemorySource.java index 3060dbeb25..826a4ff1e8 100644 --- a/data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/plugins/InMemorySource.java +++ b/data-prepper-core/src/integrationTest/java/org/opensearch/dataprepper/plugins/InMemorySource.java @@ -26,7 +26,7 @@ */ @DataPrepperPlugin(name = "in_memory", pluginType = Source.class, pluginConfigurationType = InMemoryConfig.class) public class InMemorySource implements Source> { - public static final Duration ACK_EXPIRY_TIME = Duration.ofSeconds(35); + public static final Duration ACK_EXPIRY_TIME = Duration.ofSeconds(60); private static final Logger LOG = LoggerFactory.getLogger(InMemorySource.class); private final String testingKey;