From 19d8cb23482e4516a3ec5491b874f57e22137229 Mon Sep 17 00:00:00 2001
From: ivan <ivan@ivanLaptop>
Date: Mon, 24 Aug 2015 08:23:53 +0200
Subject: [PATCH] maxErrorRetry is configurable
---
s3/src/main/java/com/yahoo/ycsb/db/S3Client.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/s3/src/main/java/com/yahoo/ycsb/db/S3Client.java b/s3/src/main/java/com/yahoo/ycsb/db/S3Client.java
index 3a4ce9fd..0a8bc9d9 100644
--- a/s3/src/main/java/com/yahoo/ycsb/db/S3Client.java
+++ b/s3/src/main/java/com/yahoo/ycsb/db/S3Client.java
@@ -54,6 +54,7 @@ public class S3Client extends DB {
private static String secretKey;
private static String endPoint;
private static String region;
+ private static String maxErrorRetry;
private static BasicAWSCredentials s3Credentials;
private static AmazonS3Client s3Client;
private static ClientConfiguration clientConfig;
@@ -102,10 +103,11 @@ public class S3Client extends DB {
secretKey = props.getProperty("s3.secretKey","secretKey");
endPoint = props.getProperty("s3.endPoint","s3.amazonaws.com");
region = props.getProperty("s3.region","us-east-1");
+ maxErrorRetry = props.getProperty("s3.maxErrorRetry","15");
System.out.println("Inizializing the S3 connection");
s3Credentials = new BasicAWSCredentials(accessKeyId,secretKey);
clientConfig = new ClientConfiguration();
- clientConfig.setMaxErrorRetry(15);
+ clientConfig.setMaxErrorRetry(Integer.parseInt(maxErrorRetry));
try {
s3Client = new AmazonS3Client(s3Credentials,clientConfig);
s3Client.setRegion(Region.getRegion(Regions.fromName(region)));
--
GitLab