summaryrefslogtreecommitdiffstats
path: root/config-proxy
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2023-02-01 13:20:10 +0100
committerHarald Musum <musum@yahooinc.com>2023-02-01 13:20:10 +0100
commit88af4ae0b13faba664f9d5d5c77d37a6b6f09498 (patch)
tree872662e5f4cc2ee580510f2869f191b685b67b23 /config-proxy
parent179daa38c12471ec9de4e48ec91865c8a336d8a8 (diff)
Stop using file distribution feature flags, not needed anymore
Diffstat (limited to 'config-proxy')
-rw-r--r--config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionAndUrlDownload.java21
1 files changed, 2 insertions, 19 deletions
diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionAndUrlDownload.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionAndUrlDownload.java
index 3107f9029d8..9e6a54d8e2c 100644
--- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionAndUrlDownload.java
+++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/filedistribution/FileDistributionAndUrlDownload.java
@@ -6,14 +6,6 @@ import com.yahoo.jrt.Supervisor;
import com.yahoo.vespa.filedistribution.FileDistributionConnectionPool;
import com.yahoo.vespa.filedistribution.FileDownloader;
import java.time.Duration;
-import java.util.Arrays;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-import static com.yahoo.vespa.filedistribution.FileReferenceData.CompressionType;
-import static com.yahoo.vespa.filedistribution.FileReferenceData.CompressionType.gzip;
-import static com.yahoo.vespa.filedistribution.FileReferenceData.CompressionType.lz4;
-import static com.yahoo.vespa.filedistribution.FileReferenceData.CompressionType.zstd;
/**
* Keeps track of file distribution and url download rpc servers.
@@ -41,18 +33,9 @@ public class FileDistributionAndUrlDownload {
private FileDownloader createDownloader(Supervisor supervisor, ConfigSourceSet source) {
return new FileDownloader(new FileDistributionConnectionPool(source, supervisor),
supervisor,
- Duration.ofMinutes(5),
- acceptedCompressionTypes());
+ Duration.ofMinutes(5));
}
- private Set<CompressionType> acceptedCompressionTypes() {
- Set<CompressionType> acceptedCompressionTypes = Set.of(gzip, lz4, zstd);
- String env = System.getenv("VESPA_FILE_DISTRIBUTION_ACCEPTED_COMPRESSION_TYPES");
- if (env != null && ! env.isEmpty()) {
- String[] types = env.split(",");
- acceptedCompressionTypes = Arrays.stream(types).map(CompressionType::valueOf).collect(Collectors.toSet());
- }
- return acceptedCompressionTypes;
- }
+
}