Observation in ServerHttpObservationFilter is never stopped for asynchronous requests

[wojtassi]

Spring Framework 6.0.19
CometD 7.0.10
Micrometer 1.12.5

I'm not exactly sure which component is responsible for this issue but since spring-web contains ServerHttpObservationFilter, I am submitting this bug here.
We have recently run into a memory leak of DefaultLongTaskTimer$SampleImpl. This was introduced with micrometer introducing histograms for http.server.requests.active.

The leak happens only for requests to CometD and it happens because those requests are asynchronous.
In https://github.com/spring-projects/spring-framework/blob/main/spring-web/src/main/java/org/springframework/web/filter/ServerHttpObservationFilter.java:

1. Observation is created at the start of doFilterInternal.
2. In synchronous requests, Observation is closed at the end of that function.
3. For asynchronous requests, Observation is never closed, by design, which was fine until histograms were introduced that use Observation.stop to stop DefaultLongTaskTimer$SampleImpl.
4. Since Observation is never stopped, we end up with DefaultLongTaskTimer$SampleImpl leak

The problem is that there is no corresponding callback that would close the Observation once asynchronous requests completes.

Thanks,

[bclozel]

We do manage async requests for many use cases with Spring MVC and WebFlux - @Async annotated requests, methods return reactive types like Flux, etc.

We have not seen any leak for observations there. I have just checked with a simple application and I'm seeing observations being closed properly, and the "http.server.requests.active" request count decrease as expected when streaming requests are done.

The ServerHttpObservationFilter should work fine with asynchronous requests. The Servlet container is responsible for REQUEST and ASYNC dispatches, involving the filter again when async processing is done. What makes you think that this approach is not correct?

Can you share a minimal sample application that shows the problem? As we don't support CometD in our stack, please bear in mind that we can only justify spending time on a very minimal sample, ideally using an application generated on start.spring.io as a baseline.

[fogninid]

We are experiencing a very similar leak on a spring boot application configured to use jersey asynchronous requests.

Can you have a look at the reproducer I pushed to https://github.com/fogninid/spring-framework-32730?

On my machine a few minutes are sufficient to get a heap dump showing this memory leak: simply run mvn test.

While the test is running, you can also observe how the values of the /actuator/metrics/http.server.requests.active delivers non-plausible and increasing values, although all requests are already completed.

[wojtassi]

Thanks @fogninid for reproducer. That saved me from carving out a sample from our production code.

The ServerHttpObservationFilter should work fine with asynchronous requests. The Servlet container is responsible for REQUEST and ASYNC dispatches, involving the filter again when async processing is done. What makes you think that this approach is not correct?

This is the part that I did not understand. I just didn't see this behavior in the code for cometD and then I found this snippet:
https://docs.spring.io/spring-framework/reference/web/webmvc/mvc-ann-async.html#mvc-ann-async-vs-webflux.
Which let me to try it out using DeferredResult:
https://github.com/wojtassi/spring-framework-32730
I've modified @fogninid reproducer to also include a sample that uses DeferredResult that does not leak. If I put a breakpoint in ServerHttpObservationFilter, it indeed is called twice. Once when initial request is created and once when async response completes.

So it appears that this Observation mechanism does not work with jakarta.ws.rs annotations that returns AsyncResponse.
For those Observations to work it needs to use DeferredResult which is spring specific.

[wojtassi]

For people that are running into this leak here is a bean that can be used to disable observations for specific endpoints:

private static final List<String> COMETD_ENDPOINTS = List.of(
            "/notifications/connect",
           "/notifications/connect/",
            "/notifications/handshake",
            "/notifications/handshake/",
            "/notifications/subscribe",
            "/notifications/subscribe/",
            "/notifications/disconnect",
            "/notifications/disconnect/");

@Bean
    ObservationPredicate micrometerCometDContextExclusionPredicate() {
        return (name, context) -> {
            if (name.equals("http.server.requests") && context instanceof ServerRequestObservationContext serverContext) {
                final String requestURI = serverContext.getCarrier().getRequestURI().toLowerCase(Locale.ENGLISH);
                if (requestURI.contains("notifications")) {
                    return !COMETD_ENDPOINTS.stream().anyMatch(m -> requestURI.endsWith(m));
                }
            }
            return true;
        };
    }

based on this:
spring-projects/spring-boot#34801

This is specific to cometD but should be easily adaptable to other end points.