Fix RequestLoggerController concurrency issues

trinodb · Jan 21, 2025 · 97b4f9e · 97b4f9e
1 parent da51b88
commit 97b4f9e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/trino-aws-proxy/src/main/java/io/trino/aws/proxy/server/rest/RequestLoggerController.java b/trino-aws-proxy/src/main/java/io/trino/aws/proxy/server/rest/RequestLoggerController.java
@@ -18,6 +18,7 @@
 import com.google.common.base.Throwables;
 import com.google.common.collect.EvictingQueue;
 import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.Queues;
 import com.google.inject.Inject;
 import io.airlift.log.Logger;
 import io.trino.aws.proxy.server.TrinoAwsProxyConfig;
@@ -146,7 +147,7 @@ public static String eventId(Instant timestamp, long requestNumber, EventType ev
     public RequestLoggerController(TrinoAwsProxyConfig trinoAwsProxyConfig)
     {
         // *2 because we log request/response
-        saveQueue = EvictingQueue.create(trinoAwsProxyConfig.getRequestLoggerSavedQty() * 2);
+        saveQueue = Queues.synchronizedQueue(EvictingQueue.create(trinoAwsProxyConfig.getRequestLoggerSavedQty() * 2));
         saveQueueEnabled = (trinoAwsProxyConfig.getRequestLoggerSavedQty() > 0);
     }