You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tika.apache.org by ta...@apache.org on 2022/09/02 14:32:04 UTC
[tika] branch main updated: TIKA-3831 -- fix off by one bug that caused a 30 second sleep and reconnect on every fetch.
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 <ta...@apache.org>
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 {