set connection TTL (#7)

trocco-io · Mar 5, 2025 · 8cdf365 · 8cdf365
1 parent e2ecc8d
commit 8cdf365
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/org/embulk/input/cloudwatch_logs/AbstractCloudwatchLogsInputPlugin.java b/src/main/java/org/embulk/input/cloudwatch_logs/AbstractCloudwatchLogsInputPlugin.java
@@ -225,6 +225,7 @@ protected ClientConfiguration getClientConfiguration(PluginTask task)
 //        clientConfig.setMaxErrorRetry(3); // SDK default: 3
         clientConfig.setSocketTimeout(8 * 60 * 1000); // SDK default: 50*1000
         clientConfig.setRetryPolicy(PredefinedRetryPolicies.NO_RETRY_POLICY);
+        clientConfig.setConnectionTTL(30 * 1000); // default: -1
         // TODO: implement http proxy
 
         return clientConfig;