feat: Replace deprecated Doppler recentLogs with Log Cache client 5.X.X - #1348
Merged
Kehrlann merged 24 commits intoMar 27, 2026
Merged
Kehrlann merged 24 commits into
Kehrlann merged 24 commits into
Conversation
Copy link
Copy Markdown
Contributor
Sorry, something went wrong.
* because of the findFirst() on the envelopes, it could be type OUT or ERR, so we don't really care, as long as the payload is the same. Also, we don't care about the precise argument to the recentLogs call
The old "Applications.logs" method is keept for compatibility and when a log stream is needed. Adding new "logsRecent" method to access the logCache. integration-tests "ApplicationTest.logs" and "ApplicationTest.logsRecent" work. Minor changes in DefaultApplicationsTest in other JUnit tests to make them execute in Eclipse.
Use LogCacheClient.read() for recent logs (the default), fall back to Doppler streaming when recent is explicitly false. Remove logCacheLogs() integration test — it was a temporary reference for the direct LogCache API, now redundant since logs() exercises the same path. Remove logsRecent() and its helpers likewise.
LogCache has been available since cf-deployment v3.0.0 (July 2018). Lower the version gate from PCF_4_v2 to PCF_2_3 and update the javadoc to reflect that the test now exercises the LogCache-backed path.
logs(ApplicationLogsRequest) now uses Log Cache internally, so Operations API users do not need to migrate.
Kehrlann
approved these changes
Mar 27, 2026
Kehrlann
left a comment
Copy link
Copy Markdown
Contributor
There was a problem hiding this comment.
Looks good. I'm provisioning an environment, will run integration tests.
Sorry, something went wrong.
Copy link
Copy Markdown
Contributor
|
Works locally. Thank you both for your contribution! |
Sorry, something went wrong.
jorbaum
added a commit
to jorbaum/cf-java-client
that referenced
this pull request
Mar 30, 2026
Remove DopplerClient.recentLogs(), RecentLogsRequest, Applications.logs(LogsRequest), and LogsRequest — all deprecated in 5.x (cloudfoundry#1348). Inline the Doppler streaming path directly into logs(ApplicationLogsRequest). Update README with breaking changes.
jorbaum
added a commit
to jorbaum/cf-java-client
that referenced
this pull request
Apr 14, 2026
…tionLogsRequest) PR cloudfoundry#1348 changed the null-recent behavior from Doppler streaming to Log Cache. This restores the original default so null behaves like false (streaming), matching the prior logs(LogsRequest) contract.
jorbaum
added a commit
to jorbaum/cf-java-client
that referenced
this pull request
Apr 14, 2026
PR cloudfoundry#1348 changed the null-recent behavior from Doppler streaming to Log Cache. This restores the original default so null behaves like false (streaming), matching the prior logs(LogsRequest) contract.
jorbaum
added a commit
to jorbaum/cf-java-client-recentlogs-demo
that referenced
this pull request
Apr 14, 2026
Two minimal standalone Java CLI apps for cf-java-client 5.17.0.BUILD-SNAPSHOT that fetch recent logs for a CF application. Both read ~/.cf/config.json for auth — no manual credential configuration needed. Tested on CF-on-kind (Loggregator >= 107.0): - LogCacheClient.read() works - DopplerClient.recentLogs() fails (no Doppler endpoint) Related: cloudfoundry/cf-java-client#1348
Kehrlann
pushed a commit
that referenced
this pull request
Apr 16, 2026
PR #1348 changed the null-recent behavior from Doppler streaming to Log Cache. This restores the original default so null behaves like false (streaming), matching the prior logs(LogsRequest) contract.
jorbaum
added a commit
to jorbaum/cf-java-client
that referenced
this pull request
Apr 17, 2026
jorbaum
added a commit
to jorbaum/cf-java-client
that referenced
this pull request
Apr 17, 2026
PR cloudfoundry#1348 changed the null-recent behavior from Doppler streaming to Log Cache. This restores the original default so null behaves like false (streaming), matching the prior logs(LogsRequest) contract.
6 tasks done
jorbaum
added a commit
to jorbaum/cf-java-client
that referenced
this pull request
May 22, 2026
Remove DopplerClient.recentLogs(), RecentLogsRequest, Applications.logs(LogsRequest), and LogsRequest — all deprecated in 5.x (cloudfoundry#1348). Inline the Doppler streaming path directly into logs(ApplicationLogsRequest). Update README with breaking changes.
jorbaum
added a commit
to jorbaum/cf-java-client
that referenced
this pull request
May 22, 2026
Remove DopplerClient.recentLogs(), RecentLogsRequest, Applications.logs(LogsRequest), and LogsRequest — all deprecated in 5.x (cloudfoundry#1348). Inline the Doppler streaming path directly into logs(ApplicationLogsRequest). Update README with breaking changes.
Kehrlann
pushed a commit
that referenced
this pull request
Jun 29, 2026
* Remove deprecated Doppler recentLogs and LogsRequest for 6.x Remove DopplerClient.recentLogs(), RecentLogsRequest, Applications.logs(LogsRequest), and LogsRequest — all deprecated in 5.x (#1348). Inline the Doppler streaming path directly into logs(ApplicationLogsRequest). Update README with breaking changes.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Rebases #1237 on top of the 5.x.x branch.
All feedback of #1237 and ZPascal#2 should be addressed:
Integrationtest results
I did not rerun the integration tests successfully on my dev environment for this 5.x.x branch so far as I ran into UAA rate limiting issues.
Previous runs with main as baseLogCacheTest
ApplicationsTest
$ ./mvnw -Pintegration-test clean test -Dgpg.skip=true \ -f integration-test/pom.xml -Dtest="org.cloudfoundry.operations.ApplicationsTest" \ -Dsurefire.reportFormat=plain [INFO] Scanning for projects... [INFO] [INFO] -----------------< org.cloudfoundry:integration-test >------------------ [INFO] Building Integration Test 6.0.0-SNAPSHOT [INFO] from pom.xml [INFO] --------------------------------[ jar ]--------------------------------- [INFO] [INFO] --- clean:3.2.0:clean (default-clean) @ integration-test --- [INFO] Deleting /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/target [INFO] [INFO] --- resources:3.3.1:resources (default-resources) @ integration-test --- [INFO] skip non existing resourceDirectory /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/main/resources [INFO] [INFO] --- compiler:3.14.0:compile (default-compile) @ integration-test --- [INFO] No sources to compile [INFO] [INFO] --- resources:3.3.1:testResources (default-testResources) @ integration-test --- [INFO] Copying 15 resources from src/test/resources to target/test-classes [INFO] [INFO] --- compiler:3.14.0:testCompile (default-testCompile) @ integration-test --- [INFO] Recompiling the module because of changed source code. [INFO] Compiling 104 source files with javac [forked debug parameters target 21] to target/test-classes [WARNING] [path] bad path element "/Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/target/classes": no such file or directory [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[22,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[24,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[26,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[28,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[30,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[32,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[34,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[36,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[38,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[40,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[42,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[44,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[46,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[48,19] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[50,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[52,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[54,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[56,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[58,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[60,20] [deprecation] forIntegers(int,int,int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersion.java:[62,23] [deprecation] forIntegers(int) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersionConditionalRule.java:[62,39] [deprecation] lessThan(Version) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersionConditionalRule.java:[67,37] [deprecation] lessThanOrEqualTo(Version) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersionConditionalRule.java:[77,37] [deprecation] greaterThanOrEqualTo(Version) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/CloudFoundryVersionConditionalRule.java:[82,39] [deprecation] greaterThan(Version) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/IntegrationTestConfiguration.java:[474,40] [deprecation] valueOf(String) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/client/v2/ApplicationsTest.java:[1514,34] [deprecation] getNextTarEntry() in TarArchiveInputStream has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/client/v2/InfoTest.java:[45,54] [deprecation] valueOf(String) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/client/v2/InfoTest.java:[46,52] [deprecation] valueOf(String) in Version has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/operations/ApplicationsTest.java:[2067,16] [deprecation] createShared(CreateSharedDomainRequest) in Domains has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/operations/DomainsTest.java:[110,16] [deprecation] createShared(CreateSharedDomainRequest) in Domains has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/operations/DomainsTest.java:[126,16] [deprecation] createShared(CreateSharedDomainRequest) in Domains has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/operations/DomainsTest.java:[283,16] [deprecation] createShared(CreateSharedDomainRequest) in Domains has been deprecated [WARNING] /Users/myuser/Workspace/public/cloudfoundry/cf-java-client/integration-test/src/test/java/org/cloudfoundry/operations/RoutesTest.java:[867,16] [deprecation] createShared(CreateSharedDomainRequest) in Domains has been deprecated [INFO] [INFO] --- surefire:3.5.3:test (default-test) @ integration-test --- [INFO] Tests will run in random order. To reproduce ordering use flag -Dsurefire.runOrder.random.seed=23180634971125 [INFO] Using auto detected provider org.apache.maven.surefire.junitplatform.JUnitPlatformProvider [INFO] [INFO] ------------------------------------------------------- [INFO] T E S T S [INFO] ------------------------------------------------------- [INFO] Running org.cloudfoundry.operations.ApplicationsTest 15:41:50.909 main io.netty.resolver.dns.DnsServerAddressStreamProviders Unable to load io.netty.resolver.dns.macos.MacOSDnsServerAddressStreamProvider, fallback to system defaults. This may result in incorrect DNS resolutions on MacOS. Check whether you have a dependency on 'io.netty:netty-resolver-dns-native-macos'. Use DEBUG level to see the full stack: java.lang.UnsatisfiedLinkError: failed to load the required native library 15:41:51.779 cloudfoundry-client-nio-2 cloudfoundry-client.compatibility Client supports API version 2.272.0 and is connected to server with API version 2.278.0. Things may not work as expected. 15:41:51.788 main cloudfoundry-client.test Performing clean slate cleanup. Should happen once per integration test run. 15:42:07.413 cloudfoundry-client-nio-1 cloudfoundry-client.compatibility Client supports API version 2.272.0 and is connected to server with API version 2.278.0. Things may not work as expected. OpenJDK 64-Bit Server VM warning: Sharing is only supported for boot loader classes because bootstrap classpath has been appended WARNING: A Java agent has been loaded dynamically (/Users/myuser/.m2/repository/net/bytebuddy/byte-buddy-agent/1.14.10/byte-buddy-agent-1.14.10.jar) WARNING: If a serviceability tool is in use, please run with -XX:+EnableDynamicAgentLoading to hide this warning WARNING: If a serviceability tool is not in use, please run with -Djdk.instrument.traceUsage for more information WARNING: Dynamic loading of agents will be disallowed by default in a future release 15:57:37.162 main org.springframework.beans.factory.support.DisposableBeanAdapter Invocation of destroy method failed on bean with name 'cloudFoundryCleaner': reactor.core.Exceptions$ReactiveException: io.netty.channel.AbstractChannel$AnnotatedConnectException: Operation timed out: api.cf.my.dev.environment.domain/XXX.XXX.XXX.XXX:XXX [ERROR] Tests run: 57, Failures: 2, Errors: 0, Skipped: 4, Time elapsed: 946.7 s <<< FAILURE! -- in org.cloudfoundry.operations.ApplicationsTest [ERROR] org.cloudfoundry.operations.ApplicationsTest.getManifest -- Time elapsed: 5.626 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.startStarted -- Time elapsed: 12.78 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.sshEnabled -- Time elapsed: 20.08 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.unsetEnvironmentVariableComplete -- Time elapsed: 26.20 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.disableSsh -- Time elapsed: 13.87 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.restartNotStarted -- Time elapsed: 17.94 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushRouteAndRoutePath -- Time elapsed: 16.38 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushDomainHostPathRoute -- Time elapsed: 12.20 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushMultipleRoutes -- Time elapsed: 16.62 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushTcpRoute skipped [ERROR] org.cloudfoundry.operations.ApplicationsTest.getTcp skipped [ERROR] org.cloudfoundry.operations.ApplicationsTest.listTasks -- Time elapsed: 13.07 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.startNotStarted -- Time elapsed: 24.89 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.terminateTask -- Time elapsed: 17.57 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushPrivateDomain -- Time elapsed: 10.65 s <<< FAILURE! java.lang.AssertionError: expectation "expectComplete" failed (expected: onComplete(); actual: onError(io.netty.channel.AbstractChannel$AnnotatedConnectException: Operation timed out: api.cf.my.dev.environment.domain/XXX.XXX.XXX.XXX:XXX)) at reactor.test.MessageFormatter.assertionError(MessageFormatter.java:115) at reactor.test.MessageFormatter.failPrefix(MessageFormatter.java:104) at reactor.test.MessageFormatter.fail(MessageFormatter.java:73) at reactor.test.MessageFormatter.failOptional(MessageFormatter.java:88) at reactor.test.DefaultStepVerifierBuilder.lambda$expectComplete$4(DefaultStepVerifierBuilder.java:344) at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:2289) at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1529) at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1477) at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onError(DefaultStepVerifierBuilder.java:1129) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onError(MonoIgnoreThen.java:279) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onError(MonoIgnoreElements.java:84) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onError(MonoFlatMapMany.java:255) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerError(FluxFlatMap.java:867) at reactor.core.publisher.FluxFlatMap$FlatMapInner.onError(FluxFlatMap.java:994) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:455) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerError(FluxFlatMap.java:867) at reactor.core.publisher.FluxFlatMap$FlatMapInner.onError(FluxFlatMap.java:994) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onError(MonoIgnoreThen.java:279) at reactor.core.publisher.MonoWhen$WhenInner.onError(MonoWhen.java:423) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:180) at reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:157) at reactor.core.publisher.MonoNext$NextSubscriber.onError(MonoNext.java:93) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRepeatWhen$RepeatWhenMainSubscriber.onError(FluxRepeatWhen.java:151) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onError(FluxFilterFuseable.java:162) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onError(FluxMapFuseable.java:340) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315) at reactor.core.publisher.MonoSingle$SingleSubscriber.onError(MonoSingle.java:150) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:455) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:455) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:455) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.whenError(FluxRetryWhen.java:228) at reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onError(FluxRetryWhen.java:278) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.maybeOnError(FluxConcatMapNoPrefetch.java:326) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:211) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) at reactor.core.publisher.SinkManyEmitterProcessor.drain(SinkManyEmitterProcessor.java:476) at reactor.core.publisher.SinkManyEmitterProcessor$EmitterInner.drainParent(SinkManyEmitterProcessor.java:620) at reactor.core.publisher.FluxPublish$PubSubInner.request(FluxPublish.java:874) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:336) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.Operators$DeferredSubscription.request(Operators.java:1743) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onError(FluxRetryWhen.java:195) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onError(MonoFlatMapMany.java:204) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.whenError(FluxRetryWhen.java:228) at reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onError(FluxRetryWhen.java:278) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.maybeOnError(FluxConcatMapNoPrefetch.java:326) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:211) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) at reactor.core.publisher.SinkManyEmitterProcessor.drain(SinkManyEmitterProcessor.java:476) at reactor.core.publisher.SinkManyEmitterProcessor$EmitterInner.drainParent(SinkManyEmitterProcessor.java:620) at reactor.core.publisher.FluxPublish$PubSubInner.request(FluxPublish.java:874) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:336) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.Operators$DeferredSubscription.request(Operators.java:1743) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onError(FluxRetryWhen.java:195) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.http.client.HttpClientConnect$MonoHttpConnect$ClientTransportSubscriber.onError(HttpClientConnect.java:311) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.resources.DefaultPooledConnectionProvider$DisposableAcquire.onError(DefaultPooledConnectionProvider.java:172) at reactor.netty.internal.shaded.reactor.pool.AbstractPool$Borrower.fail(AbstractPool.java:488) at reactor.netty.internal.shaded.reactor.pool.SimpleDequePool.lambda$drainLoop$9(SimpleDequePool.java:433) at reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber.onError(FluxDoOnEach.java:186) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.resources.DefaultPooledConnectionProvider$PooledConnectionAllocator$PooledConnectionInitializer.onError(DefaultPooledConnectionProvider.java:583) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:106) at reactor.core.publisher.Operators.error(Operators.java:198) at reactor.core.publisher.MonoError.subscribe(MonoError.java:53) at reactor.core.publisher.Mono.subscribe(Mono.java:4512) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.netty.transport.TransportConnector$MonoChannelPromise.tryFailure(TransportConnector.java:576) at reactor.netty.transport.TransportConnector$MonoChannelPromise.setFailure(TransportConnector.java:522) at reactor.netty.transport.TransportConnector.lambda$doConnect$7(TransportConnector.java:261) at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:590) at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:583) at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:559) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:492) at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:636) at io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:629) at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:118) at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:322) at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:338) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) Suppressed: io.netty.channel.AbstractChannel$AnnotatedConnectException: Operation timed out: api.cf.my.dev.environment.domain/XXX.XXX.XXX.XXX:XXX Suppressed: The stacktrace has been enhanced by Reactor, refer to additional information below: Assembly trace from producer [reactor.core.publisher.MonoFlatMap] : reactor.core.publisher.Mono.checkpoint(Mono.java:2206) org.cloudfoundry.reactor.client.v2.jobs.ReactorJobs.get(ReactorJobs.java:55) Error has been observed at the following site(s): *__checkpoint() ⇢ at org.cloudfoundry.reactor.client.v2.jobs.ReactorJobs.get(ReactorJobs.java:55) *__checkpoint() ⇢ at org.cloudfoundry.operations.applications.DefaultApplications.pushManifest(DefaultApplications.java:678) |_ checkpoint() ⇢ at org.cloudfoundry.operations.applications.DefaultApplications.push(DefaultApplications.java:624) Original Stack Trace: Caused by: java.net.ConnectException: Operation timed out at java.base/sun.nio.ch.Net.pollConnect(Native Method) at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:694) at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:973) at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:337) at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:335) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) [ERROR] org.cloudfoundry.operations.ApplicationsTest.rename -- Time elapsed: 12.53 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.copySource -- Time elapsed: 35.15 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushManifestV3WithMetadata -- Time elapsed: 33.83 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.getStopped -- Time elapsed: 2.808 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushManifestV3MultipleApplications -- Time elapsed: 21.24 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.getMultipleBuildpacks -- Time elapsed: 4.929 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.enableSsh -- Time elapsed: 13.03 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.getMultipleBuildpacksManifest -- Time elapsed: 8.996 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushExisting -- Time elapsed: 21.84 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushNew -- Time elapsed: 25.16 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushUpdateTcpRoute skipped [ERROR] org.cloudfoundry.operations.ApplicationsTest.unsetEnvironmentVariablePartial -- Time elapsed: 25.83 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.setHealthCheck -- Time elapsed: 13.07 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.get -- Time elapsed: 10.87 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.list -- Time elapsed: 17.01 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.logs -- Time elapsed: 13.36 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.stop -- Time elapsed: 14.44 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushManifestMultipleBuildpacks -- Time elapsed: 2.842 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.scale -- Time elapsed: 20.25 s <<< FAILURE! java.lang.AssertionError: expectation "expectNext(2)" failed (expected: onNext(2); actual: onError(io.netty.channel.AbstractChannel$AnnotatedConnectException: Operation timed out: api.cf.my.dev.environment.domain/XXX.XXX.XXX.XXX:XXX)) at reactor.test.MessageFormatter.assertionError(MessageFormatter.java:115) at reactor.test.MessageFormatter.failPrefix(MessageFormatter.java:104) at reactor.test.MessageFormatter.fail(MessageFormatter.java:73) at reactor.test.MessageFormatter.failOptional(MessageFormatter.java:88) at reactor.test.DefaultStepVerifierBuilder.lambda$addExpectedValue$10(DefaultStepVerifierBuilder.java:509) at reactor.test.DefaultStepVerifierBuilder$SignalEvent.test(DefaultStepVerifierBuilder.java:2289) at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onSignal(DefaultStepVerifierBuilder.java:1529) at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onExpectation(DefaultStepVerifierBuilder.java:1477) at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.onError(DefaultStepVerifierBuilder.java:1129) at reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onError(MonoIgnoreThen.java:279) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onError(MonoIgnoreElements.java:84) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onError(MonoFlatMapMany.java:255) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerError(FluxFlatMap.java:867) at reactor.core.publisher.FluxFlatMap$FlatMapInner.onError(FluxFlatMap.java:994) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerError(FluxFlatMap.java:867) at reactor.core.publisher.FluxFlatMap$FlatMapInner.onError(FluxFlatMap.java:994) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onError(MonoIgnoreThen.java:279) at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onError(MonoIgnoreElements.java:84) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:106) at reactor.core.publisher.Operators.error(Operators.java:198) at reactor.core.publisher.MonoError.subscribe(MonoError.java:53) at reactor.core.publisher.Mono.subscribe(Mono.java:4512) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onError(Operators.java:2236) at reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:157) at reactor.core.publisher.MonoNext$NextSubscriber.onError(MonoNext.java:93) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRepeatWhen$RepeatWhenMainSubscriber.onError(FluxRepeatWhen.java:151) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onError(FluxFilterFuseable.java:162) at reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onError(MonoReduceSeed.java:153) at reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onError(MonoFlatMapMany.java:204) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onError(FluxOnAssembly.java:544) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315) at reactor.core.publisher.MonoSingle$SingleSubscriber.onError(MonoSingle.java:150) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:455) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:455) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:846) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:592) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onError(FluxFlatMap.java:455) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.whenError(FluxRetryWhen.java:228) at reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onError(FluxRetryWhen.java:278) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.maybeOnError(FluxConcatMapNoPrefetch.java:326) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:211) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) at reactor.core.publisher.SinkManyEmitterProcessor.drain(SinkManyEmitterProcessor.java:476) at reactor.core.publisher.SinkManyEmitterProcessor$EmitterInner.drainParent(SinkManyEmitterProcessor.java:620) at reactor.core.publisher.FluxPublish$PubSubInner.request(FluxPublish.java:874) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:336) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.Operators$DeferredSubscription.request(Operators.java:1743) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onError(FluxRetryWhen.java:195) at reactor.core.publisher.FluxPeek$PeekSubscriber.onError(FluxPeek.java:222) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onError(MonoFlatMapMany.java:204) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315) at reactor.core.publisher.SerializedSubscriber.onError(SerializedSubscriber.java:124) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.whenError(FluxRetryWhen.java:228) at reactor.core.publisher.FluxRetryWhen$RetryWhenOtherSubscriber.onError(FluxRetryWhen.java:278) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.maybeOnError(FluxConcatMapNoPrefetch.java:326) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onNext(FluxConcatMapNoPrefetch.java:211) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) at reactor.core.publisher.SinkManyEmitterProcessor.drain(SinkManyEmitterProcessor.java:476) at reactor.core.publisher.SinkManyEmitterProcessor$EmitterInner.drainParent(SinkManyEmitterProcessor.java:620) at reactor.core.publisher.FluxPublish$PubSubInner.request(FluxPublish.java:874) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:336) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.request(FluxContextWrite.java:136) at reactor.core.publisher.Operators$DeferredSubscription.request(Operators.java:1743) at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.onError(FluxRetryWhen.java:195) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.http.client.HttpClientConnect$MonoHttpConnect$ClientTransportSubscriber.onError(HttpClientConnect.java:311) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.resources.DefaultPooledConnectionProvider$DisposableAcquire.onError(DefaultPooledConnectionProvider.java:172) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onError(FluxContextWrite.java:121) at reactor.netty.internal.shaded.reactor.pool.AbstractPool$Borrower.fail(AbstractPool.java:488) at reactor.netty.internal.shaded.reactor.pool.SimpleDequePool.lambda$drainLoop$9(SimpleDequePool.java:433) at reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber.onError(FluxDoOnEach.java:186) at reactor.core.publisher.MonoCreate$DefaultMonoSink.error(MonoCreate.java:205) at reactor.netty.resources.DefaultPooledConnectionProvider$PooledConnectionAllocator$PooledConnectionInitializer.onError(DefaultPooledConnectionProvider.java:583) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:241) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:315) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:106) at reactor.core.publisher.Operators.error(Operators.java:198) at reactor.core.publisher.MonoError.subscribe(MonoError.java:53) at reactor.core.publisher.Mono.subscribe(Mono.java:4512) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) at reactor.netty.transport.TransportConnector$MonoChannelPromise.tryFailure(TransportConnector.java:576) at reactor.netty.transport.TransportConnector$MonoChannelPromise.setFailure(TransportConnector.java:522) at reactor.netty.transport.TransportConnector.lambda$doConnect$7(TransportConnector.java:261) at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:590) at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:583) at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:559) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:492) at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:636) at io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:629) at io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:118) at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:322) at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:338) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) Suppressed: io.netty.channel.AbstractChannel$AnnotatedConnectException: Operation timed out: api.cf.my.dev.environment.domain/XXX.XXX.XXX.XXX:XXX Suppressed: The stacktrace has been enhanced by Reactor, refer to additional information below: Assembly trace from producer [reactor.core.publisher.MonoFlatMap] : reactor.core.publisher.Mono.checkpoint(Mono.java:2206) org.cloudfoundry.reactor.client.v2.applications.ReactorApplicationsV2.instances(ReactorApplicationsV2.java:199) Error has been observed at the following site(s): *__checkpoint() ⇢ at org.cloudfoundry.reactor.client.v2.applications.ReactorApplicationsV2.instances(ReactorApplicationsV2.java:199) *__checkpoint() ⇢ at org.cloudfoundry.operations.applications.DefaultApplications.pushManifest(DefaultApplications.java:678) |_ checkpoint() ⇢ at org.cloudfoundry.operations.applications.DefaultApplications.push(DefaultApplications.java:624) Original Stack Trace: Caused by: java.net.ConnectException: Operation timed out at java.base/sun.nio.ch.Net.pollConnect(Native Method) at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:694) at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:973) at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:337) at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:335) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:776) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushUpdateRoute -- Time elapsed: 10.56 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.getManifestForTcpRoute skipped [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushDomainNotFound -- Time elapsed: 0.523 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.getEvents -- Time elapsed: 4.819 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushWithHost -- Time elapsed: 13.82 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.restartStarted -- Time elapsed: 17.21 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.setReadinessHealthCheck -- Time elapsed: 12.16 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushNewDocker -- Time elapsed: 12.33 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushDirectory -- Time elapsed: 12.56 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.restage -- Time elapsed: 34.42 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.setEnvironmentVariable -- Time elapsed: 11.48 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.restartInstance -- Time elapsed: 20.26 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.deleteApplicationWithServiceBindings -- Time elapsed: 26.76 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.deleteApplicationAndRoutes -- Time elapsed: 17.99 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.runTask -- Time elapsed: 14.09 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.deleteApplication -- Time elapsed: 12.83 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushBindServices -- Time elapsed: 17.04 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.getHealthCheck -- Time elapsed: 4.724 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushMultipleBuildpacks -- Time elapsed: 4.879 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushNoHostName -- Time elapsed: 15.17 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushManifestV3 -- Time elapsed: 18.87 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushNoRoute -- Time elapsed: 14.55 s [ERROR] org.cloudfoundry.operations.ApplicationsTest.pushRoutePath -- Time elapsed: 25.58 s [INFO] Running org.cloudfoundry.operations.ApplicationsTest 15:57:38.015 cloudfoundry-client-nio-2 cloudfoundry-client.compatibility Client supports API version 2.272.0 and is connected to server with API version 2.278.0. Things may not work as expected. 15:57:52.672 cloudfoundry-client-nio-13 cloudfoundry-client.compatibility Client supports API version 2.272.0 and is connected to server with API version 2.278.0. Things may not work as expected. 16:00:14.922 cloudfoundry-client-nio-4 cloudfoundry-client.test Unable to delete space test-space-4raf8 org.cloudfoundry.client.v2.ClientV2Exception: UnknownError(10001): An unknown error occurred. at org.cloudfoundry.util.JobUtils.getError(JobUtils.java:123) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:132) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:82) at reactor.core.publisher.SerializedSubscriber.onNext(SerializedSubscriber.java:99) at reactor.core.publisher.FluxRepeatWhen$RepeatWhenMainSubscriber.onNext(FluxRepeatWhen.java:142) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:118) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onNext(FluxMapFuseable.java:299) at reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:539) at reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:245) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:305) at reactor.core.publisher.Operators$MonoInnerProducerBase.complete(Operators.java:2842) at reactor.core.publisher.MonoSingle$SingleSubscriber.onComplete(MonoSingle.java:180) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerComplete(FluxFlatMap.java:898) at reactor.core.publisher.FluxFlatMap$FlatMapInner.onComplete(FluxFlatMap.java:1001) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.core.publisher.FluxHandle$HandleSubscriber.onComplete(FluxHandle.java:223) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onComplete(FluxMap.java:275) at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:128) at reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) at reactor.core.publisher.Operators$BaseFluxToMonoOperator.completePossiblyEmpty(Operators.java:2098) at reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber.onComplete(MonoCollectList.java:118) at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:128) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:144) at reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:415) at reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:446) at reactor.netty.channel.ChannelOperations.terminate(ChannelOperations.java:500) at reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:780) at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:114) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436) at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346) at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318) at io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.handler.logging.LoggingHandler.channelRead(LoggingHandler.java:280) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1475) at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1338) at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1387) at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:529) at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:468) at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:290) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.base/java.lang.Thread.run(Thread.java:1583) 16:00:14.926 main org.springframework.beans.factory.support.DisposableBeanAdapter Invocation of destroy method failed on bean with name 'cloudFoundryCleaner': org.cloudfoundry.client.v2.ClientV2Exception: UnknownError(10001): An unknown error occurred. [INFO] Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 157.8 s -- in org.cloudfoundry.operations.ApplicationsTest [INFO] org.cloudfoundry.operations.ApplicationsTest.scale -- Time elapsed: 21.46 s [INFO] org.cloudfoundry.operations.ApplicationsTest.pushPrivateDomain -- Time elapsed: 15.95 s [INFO] [INFO] Results: [INFO] [WARNING] Flakes: [WARNING] org.cloudfoundry.operations.ApplicationsTest.pushPrivateDomain [ERROR] Run 1: ApplicationsTest.pushPrivateDomain expectation "expectComplete" failed (expected: onComplete(); actual: onError(io.netty.channel.AbstractChannel$AnnotatedConnectException: Operation timed out: api.cf.my.dev.environment.domain/XXX.XXX.XXX.XXX:XXX)) [INFO] Run 2: PASS [INFO] [WARNING] org.cloudfoundry.operations.ApplicationsTest.scale [ERROR] Run 1: ApplicationsTest.scale expectation "expectNext(2)" failed (expected: onNext(2); actual: onError(io.netty.channel.AbstractChannel$AnnotatedConnectException: Operation timed out: api.cf.my.dev.environment.domain/XXX.XXX.XXX.XXX:XXX)) [INFO] Run 2: PASS [INFO] [INFO] [WARNING] Tests run: 57, Failures: 0, Errors: 0, Skipped: 4, Flakes: 2 [INFO] [INFO] ------------------------------------------------------------------------ [INFO] BUILD SUCCESS [INFO] ------------------------------------------------------------------------ [INFO] Total time: 18:27 min [INFO] Finished at: 2026-03-23T16:00:14+01:00 [INFO] ------------------------------------------------------------------------