Andrew Ross

@reta Unfortunately this failed again on PR #18060 which did contain the change from #18008: ``` REPRODUCE WITH: ./gradlew ':plugins:transport-reactor-netty4:javaRestTest' --tests "org.opensearch.rest.ReactorNetty4StreamingStressIT.testCloseClientStreamingRequest" -Dtests.seed=D6B2DB4CE5B44876 -Dtests.security.manager=true -Dtests.jvm.argline="-XX:TieredStopAtLevel=1 -XX:ReservedCodeCacheSize=64m" -Dtests.locale=en-US -Dtests.timezone=Etc/GMT-7 -Druntime.java=21 ReactorNetty4StreamingStressIT...

I spent a few minutes looking into this, but couldn't figure out a fix. This is the relevant code: https://github.com/opensearch-project/OpenSearch/blob/473665fa1c8a59a42c87a7182872fb47e0a9f439/plugins/transport-reactor-netty4/src/javaRestTest/java/org/opensearch/rest/ReactorNetty4StreamingStressIT.java#L69-L80 When it fails it seems to match the first "onNext"...

@reta I had trouble reproducing this, but I can get it to fail in the same way by changing the [client close](https://github.com/opensearch-project/OpenSearch/blob/8d17c8d87e67db8924ed66ab0128f0bdc6aff274/client/rest/src/main/java/org/opensearch/client/RestClient.java#L767) call to be `client.close(CloseMode.IMMEDIATE)` so that it does...

New failure here: https://build.ci.opensearch.org/job/gradle-check/58016/ ``` REPRODUCE WITH: ./gradlew ':plugins:transport-reactor-netty4:javaRestTest' --tests "org.opensearch.rest.ReactorNetty4StreamingStressIT.testCloseClientStreamingRequest" -Dtests.seed=9151F2D61088B7C9 -Dtests.security.manager=true -Dtests.jvm.argline="-XX:TieredStopAtLevel=1 -XX:ReservedCodeCacheSize=64m" -Dtests.locale=de-LU -Dtests.timezone=US/Pacific -Druntime.java=21 ReactorNetty4StreamingStressIT > testCloseClientStreamingRequest FAILED java.lang.AssertionError: expectation "expectNextMatches" failed (expected: onNext(); actual: onError(java.util.concurrent.TimeoutException:...

Latest failure from a commit on main that did contain the most recent fix: https://build.ci.opensearch.org/job/gradle-check/58962/ ``` REPRODUCE WITH: ./gradlew ':plugins:transport-reactor-netty4:javaRestTest' --tests "org.opensearch.rest.ReactorNetty4StreamingStressIT.testCloseClientStreamingRequest" -Dtests.seed=A4C86660C6C07D13 -Dtests.security.manager=true -Dtests.jvm.argline="-XX:TieredStopAtLevel=1 -XX:ReservedCodeCacheSize=64m" -Dtests.locale=es-UY -Dtests.timezone=Etc/GMT+3 -Druntime.java=21 ReactorNetty4StreamingStressIT...

[Catch All Triage](https://github.com/opensearch-project/.github/blob/main/TRIAGING.md) - [1](https://github.com/krisfreedain) [2](https://github.com/andrross)

[Catch All Triage](https://github.com/opensearch-project/.github/blob/main/TRIAGING.md) - [1](https://github.com/andrross)

[Catch All Triage](https://github.com/opensearch-project/.github/blob/main/TRIAGING.md) - [1](https://github.com/krisfreedain) [2](https://github.com/andrross)

[Catch All Triage](https://github.com/opensearch-project/.github/blob/main/TRIAGING.md) - [1](https://github.com/andrross) [2](https://github.com/finnegancarroll) [3](https://github.com/krisfreedain)

[Catch All Triage](https://github.com/opensearch-project/.github/blob/main/TRIAGING.md) - [1](https://github.com/krisfreedain) [2](https://github.com/andrross)