fix: Exceeded limit on max bytes to buffer

eclipse · Oct 31, 2024 · 10486f3 · 10486f3
1 parent feb93c9
commit 10486f3
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/server/src/main/java/org/eclipse/jifa/server/service/impl/WorkerServiceImpl.java b/server/src/main/java/org/eclipse/jifa/server/service/impl/WorkerServiceImpl.java
@@ -65,6 +65,7 @@
 import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.reactive.function.BodyInserter;
 import org.springframework.web.reactive.function.BodyInserters;
+import org.springframework.web.reactive.function.client.ExchangeStrategies;
 import org.springframework.web.reactive.function.client.WebClient;
 import org.springframework.web.reactive.function.client.WebClientResponseException;
 import org.springframework.web.util.DefaultUriBuilderFactory;
@@ -127,7 +128,13 @@ protected WorkerServiceImpl(UserService userService,
                                           .doOnConnected(conn -> conn
                                                   .addHandlerLast(new ReadTimeoutHandler(Long.MAX_VALUE, TimeUnit.SECONDS))
                                                   .addHandlerLast(new WriteTimeoutHandler(Long.MAX_VALUE, TimeUnit.SECONDS)));
+
+        final int maxInMemorySize = 10 * 1024 * 1024;
+        final ExchangeStrategies exchangeStrategies = ExchangeStrategies.builder()
+                .codecs(configurer -> configurer.defaultCodecs().maxInMemorySize(maxInMemorySize))
+                .build();
         webClient = WebClient.builder()
+                             .exchangeStrategies(exchangeStrategies)
                              .clientConnector(new ReactorClientHttpConnector(httpClient))
                              .build();