delay log warning to 60 minutes (#6)

devrev · Nov 22, 2024 · daa66a4 · daa66a4
1 parent d1b56ce
commit daa66a4
Showing 1 changed file with 1 addition and 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
@@ -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)