FLAKY

instrumentation/spring/spring-webflux-5.0/javaagent/build.gradle.kts

@@ -52,9 +52,9 @@ dependencies {
   testCompileOnly("io.projectreactor.ipc:reactor-netty:0.7.0.RELEASE")
   testCompileOnly("io.projectreactor.netty:reactor-netty-http:1.0.7")
 
-  testLibrary("org.springframework.boot:spring-boot-starter-webflux:2.0.0.RELEASE")
-  testLibrary("org.springframework.boot:spring-boot-starter-test:2.0.0.RELEASE")
-  testLibrary("org.springframework.boot:spring-boot-starter-reactor-netty:2.0.0.RELEASE")
+  testLibrary("org.springframework.boot:spring-boot-starter-webflux:2.5.0")
+  testLibrary("org.springframework.boot:spring-boot-starter-test:2.5.0")
+  testLibrary("org.springframework.boot:spring-boot-starter-reactor-netty:2.5.0")
   testImplementation("org.spockframework:spock-spring:1.1-groovy-2.4")
 }
 
@@ -68,5 +68,8 @@ tasks.withType<Test>().configureEach {
   // a good approach. Come up with a better one and enable this.
   jvmArgs("-Dio.opentelemetry.javaagent.shaded.io.opentelemetry.context.enableStrictContext=false")
 
+//  jvmArgs("-Xint")
+//  jvmArgs("-Dio.netty.defaultPromise.maxListenerStackDepth=1")
+
   systemProperty("testLatestDeps", findProperty("testLatestDeps") as Boolean)
 }

instrumentation/spring/spring-webflux-5.0/javaagent/src/test/groovy/SpringWebfluxTest.groovy

@@ -487,7 +487,7 @@ class SpringWebfluxTest extends AgentInstrumentationSpecification {
   @Unroll
   def "Multiple GETs to delaying route #testName"() {
     setup:
-    def requestsCount = 50 // Should be more than 2x CPUs to fish out some bugs
+    def requestsCount = 300 // Should be more than 2x CPUs to fish out some bugs
     def url = "http://localhost:$port$urlPath"
     when:
     def responses = (0..requestsCount - 1).collect { client.get(urlPath).aggregate().join() }