This is an automated email from the ASF dual-hosted git repository.
tallison pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/tika.git
The following commit(s) were added to refs/heads/main by this push:
new fcdc8258f TIKA-3831 -- fix off by one bug that caused a 30 second
sleep and reconnect on every fetch.
fcdc8258f is described below
commit fcdc8258f0c8bb75c32197db7d4dbe0f333339d8
Author: tballison <[email protected]>
AuthorDate: Fri Sep 2 10:31:53 2022 -0400
TIKA-3831 -- fix off by one bug that caused a 30 second sleep and reconnect
on every fetch.
---
.../src/main/java/org/apache/tika/pipes/fetcher/s3/S3Fetcher.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/tika-pipes/tika-fetchers/tika-fetcher-s3/src/main/java/org/apache/tika/pipes/fetcher/s3/S3Fetcher.java
b/tika-pipes/tika-fetchers/tika-fetcher-s3/src/main/java/org/apache/tika/pipes/fetcher/s3/S3Fetcher.java
index 777ece96b..4e2c641f9 100644
---
a/tika-pipes/tika-fetchers/tika-fetcher-s3/src/main/java/org/apache/tika/pipes/fetcher/s3/S3Fetcher.java
+++
b/tika-pipes/tika-fetchers/tika-fetcher-s3/src/main/java/org/apache/tika/pipes/fetcher/s3/S3Fetcher.java
@@ -95,14 +95,14 @@ public class S3Fetcher extends AbstractFetcher implements
Initializable, RangeFe
int tries = 0;
IOException ex = null;
while (tries++ <= retries) {
- if (tries > 0) {
- LOGGER.debug("sleeping for 30 seconds before retry");
+ if (tries > 1) {
+ LOGGER.warn("sleeping for 30 seconds before retry");
try {
Thread.sleep(30000);
} catch (InterruptedException e) {
throw new RuntimeException("interrupted");
}
- LOGGER.debug("re-initializing S3 client");
+ LOGGER.info("trying to re-initialize S3 client");
initialize(new HashMap<>());
}
try {
