From daa66a49ffd669ea0a712985914a4e5452c1958d Mon Sep 17 00:00:00 2001 From: Divanshu Aggarwal Date: Fri, 22 Nov 2024 22:30:49 +0530 Subject: [PATCH] delay log warning to 60 minutes (#6) --- .../com/trustpilot/connector/dynamodb/kcl/KclWorkerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/src/main/java/com/trustpilot/connector/dynamodb/kcl/KclWorkerImpl.java b/source/src/main/java/com/trustpilot/connector/dynamodb/kcl/KclWorkerImpl.java index a62166a..68734e1 100644 --- a/source/src/main/java/com/trustpilot/connector/dynamodb/kcl/KclWorkerImpl.java +++ b/source/src/main/java/com/trustpilot/connector/dynamodb/kcl/KclWorkerImpl.java @@ -156,7 +156,7 @@ KinesisClientLibConfiguration getClientLibConfiguration(String tableName, .withFailoverTimeMillis(Constants.KCL_FAILOVER_TIME) // logs warning if RecordProcessor task is blocked for long time periods. - .withLogWarningForTaskAfterMillis(60 * 1000) + .withLogWarningForTaskAfterMillis(60 * 60 * 1000) // fix some random issues with https://github.com/awslabs/amazon-kinesis-client/issues/164 .withIgnoreUnexpectedChildShards(true)