Reactive StateMachine 3.2.0 blocks in Openshift 4

[itsiafa]

Hi,
I'm running a Springboot (2.5.9) service that interacts with Azure Blob Storage (SDK 12.20.1).
Java version is: 11.0.17
I invoke sync and async methods to copy blobs from a container to another one. Invoked Azure method behaves correctly when the service runs on my laptop, but blocks when it is deployed to Openshift.
I tried all the possible Azure methods (both sync and async) with no better result. I'm investigating this issue since days, including OpenShift thread config) and tried Java SDK version 11.0.9 but no success so far.

Thanks for any hint!

• Openshift Pod's OS

$ uname -a
Linux gin-backend-numerisation-dev-5897964856-vplzb 4.18.0-305.57.1.el8_4.x86_64 #1 SMP Tue Jul 5 17:55:55 EDT 2022 x86_64 x86_64 x86_64 GNU/Linux

• Openshift Pod's Java version

$ java --version
openjdk 11.0.17 2022-10-18
OpenJDK Runtime Environment Temurin-11.0.17+8 (build 11.0.17+8)
OpenJDK 64-Bit Server VM Temurin-11.0.17+8 (build 11.0.17+8, mixed mode, sharing)

• Sync Call:

        try {
            BlobContainerClient srcContainerClient = blobServiceSyncClient.getBlobContainerClient(srcContainer);
            BlobContainerClient destContainerClient = blobServiceSyncClient.getBlobContainerClient(destContainer);
            BlockBlobClient srcBlobClient = requireNonNull(srcContainerClient.getBlobClient(blobName)).getBlockBlobClient();
            BlockBlobClient destBlobClient = requireNonNull(destContainerClient.getBlobClient(blobName)).getBlockBlobClient();

            log.info("--- Begin copy of [{}] from [{}] to [{}]", blobName, srcBlobClient.getBlobUrl(), destBlobClient.getBlobUrl());
            BlobCopyInfo blobCopyInfo = destBlobClient
                    .beginCopy(srcBlobClient.getBlobUrl(), Duration.ofSeconds(2))
                    .poll()
                    .getValue();
            log.info("--- Copy ID [{}]", blobCopyInfo.getCopyId());

            return Mono.just(nonNull(blobCopyInfo.getCopyId()));
        } catch (Exception e) {
            return Mono.error(e);
        }
    }

Output

• On my laptop running Windows OS (SUCCESSFULL COPY)

2023-04-12 06:17:31.352 [GIN] [GIN-Async2] INFO  c.q.h.g.s.a.AzureBlobStorageAsyncAdapter - Copying [LZ-202202349-203262368-D.tif] from [aqdepot] to [aqrejet]
2023-04-12 06:17:32.504 [GIN] [reactor-http-nio-1] INFO  c.q.h.g.s.a.AzureBlobStorageAsyncAdapter - ----- Copy Info: status [success], Id [8f5b2933-234d-4dde-b289-1459d74ca204]
2023-04-12 06:17:32.504 [GIN] [reactor-http-nio-1] INFO  c.q.h.g.s.a.AzureBlobStorageAsyncAdapter - ------------ CopyId [8f5b2933-234d-4dde-b289-1459d74ca204]
2023-04-12 06:17:32.504 [GIN] [GIN-Async2] INFO  c.q.h.g.s.a.StateMachineAction - ----------------------- Completing future state event [REJECT_DOCUMENT_SUCCESS_EVENT]
2023-04-12 06:17:32.504 [GIN] [parallel-3] INFO  c.q.h.g.s.a.StateMachineAction - ------------------- Consumed completed future state event [REJECT_DOCUMENT_SUCCESS_EVENT]
2023-04-12 06:17:32.504 [GIN] [parallel-3] INFO  c.q.h.g.s.a.StateMachineAction - -------------------- sending event [REJECT_DOCUMENT_SUCCESS_EVENT]

• In Openshift Pod (FAILING COPY)

2023-04-12 05:31:58.995 [GIN] [GIN-Async2] INFO  c.q.h.g.s.a.AzureBlobStorageAsyncAdapter - Copying [LZ-202202349-203262368-D.tif] from [aqdepot] to [aqrejet]
2023-04-12 05:32:59.102 [GIN] [GIN-Async2] ERROR c.q.h.g.s.BlobStorageService - Timeout on blocking read for 60000000000 NANOSECONDS
java.lang.IllegalStateException: Timeout on blocking read for 60000000000 NANOSECONDS
	at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:123)
	at reactor.core.publisher.Mono.block(Mono.java:1727)
	at xxx.gin.service.BlobStorageService.blockingCopyBlob(BlobStorageService.java:50)
	at xxx.gin.statemachine.action.RejectDocumentAction.executeAction(RejectDocumentAction.java:23)
	at xxx.gin.utils.AsyncExecutor.execute(AsyncExecutor.java:17)
	at xxx.gin.utils.AsyncExecutor$$FastClassBySpringCGLIB$$cbe9f366.invoke(<generated>)
	at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:779)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750)
	at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89)
	at io.opentracing.contrib.spring.cloud.async.TraceAsyncAspect.traceBackgroundThread(TraceAsyncAspect.java:56)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
	at java.base/java.lang.reflect.Method.invoke(Unknown Source)
	at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634)
	at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624)
	at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750)
	at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
	at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:750)
	at org.springframework.aop.interceptor.AsyncExecutionInterceptor.lambda$invoke$0(AsyncExecutionInterceptor.java:115)
	at io.opentracing.contrib.concurrent.TracedCallable.call(TracedCallable.java:32)
	at java.base/java.util.concurrent.FutureTask.run(Unknown Source)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
	at java.base/java.lang.Thread.run(Unknown Source)
2023-04-12 05:32:59.103 [GIN] [GIN-Async2] INFO  c.q.h.g.s.a.StateMachineAction - ----------------------- Completing future state event [REJECT_DOCUMENT_ERROR_EVENT]
2023-04-12 05:32:59.103 [GIN] [parallel-1] INFO  c.q.h.g.s.a.StateMachineAction - ------------------- Consumed completed future state event [REJECT_DOCUMENT_ERROR_EVENT]
2023-04-12 05:32:59.103 [GIN] [parallel-1] INFO  c.q.h.g.s.a.StateMachineAction - -------------------- sending event [REJECT_DOCUMENT_ERROR_EVENT]

• Async Call, same behavior (timeout is triggered after 1 minute, as per configuration logic)

==========================================================

public Mono<Boolean> copyBlobAsync(String srcContainer, String destContainer, String blobName) {
        try {
        BlobContainerAsyncClient srcContainerClient = blobServiceClient.getBlobContainerAsyncClient(srcContainer);
        BlobContainerAsyncClient destContainerClient = blobServiceClient.getBlobContainerAsyncClient(destContainer);
        BlobAsyncClient srcBlobClient = srcContainerClient.getBlobAsyncClient(blobName);
        BlobAsyncClient destBlobClient = destContainerClient.getBlobAsyncClient(blobName);

        log.info("Copying [{}] from [{}] to [{}]", blobName, srcContainer, destContainer);

        Flux<AsyncPollResponse<BlobCopyInfo, Void>> poller = destBlobClient.beginCopy(srcBlobClient.getBlobUrl(), 
                     containerProperties.getCopyPollInterval());

            return poller
                    .shareNext()
                    .map(asyncPollRes -> {
                        log.info("------------ CopyId [{}]", asyncPollRes.getValue().getCopyId());
                        return nonNull(asyncPollRes.getValue().getCopyId());
                    })
            ;
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            return Mono.error(e);
        }
    }