Большой двоичный объект хранилища Azure получает исключение io.netty.channel.StacklessClosedChannelException при создани ⇐ JAVA

[Anonymous]

Я использую приведенный ниже код для создания ByteStream из SasUrl хранилища Azaue
ConnectionProvider ConnectionProvider =
ConnectionProvider.builder("custom-connection-provider").maxConnections(200)
.pendingAcquireMaxCount(5000)
.build();

Код: Выделить всё

        BlobClient blobClient = new BlobClientBuilder()
.endpoint(searchMultipleWrapper.getSasUrl().trim()) // IT IS MY VALID SAS URL
.httpClient(new NettyAsyncHttpClientBuilder()
.connectionProvider(connectionProvider)
.readTimeout(Duration.ofMinutes(10))
.writeTimeout(Duration.ofMinutes(10))
.responseTimeout(Duration.ofMinutes(10))
.build())
.retryOptions(new RequestRetryOptions(
RetryPolicyType.EXPONENTIAL,
5,
2,
null,
null,
null
))
.buildClient();

log.info("BlobClient Object check {} ", blobClient);

// Use try-with-resources to ensure InputStream is closed
try (InputStream inputStream = blobClient.openInputStream();
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream()) {

// Transfer data from InputStream to ByteArrayOutputStream
inputStream.transferTo(byteArrayOutputStream);

// Convert to Base64
byte[] imageBytes = byteArrayOutputStream.toByteArray();
String base64Image = Base64.getEncoder().encodeToString(imageBytes);

log.info("Base 64 : {} ", base64Image);

// Log the Base64 string (truncated for safety)
log.info("Base64 Image (truncated): " + base64Image.substring(0, Math.min(base64Image.length(), 100)) + "...");
} catch (Exception e) {
log.error("Error while processing blob content", e);

}

Исключение, которое я получаю, как показано ниже: -

stack_trace":"reactor.core.Exceptions$ReactiveException:
io.netty.channel.StacklessClosedChannelException\n\tat
Заголовок ##reactor.core.Exceptions.propagate(Exceptions.java:410)\n\tat
reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:102)\n\ тат
reactor.core.publisher.Mono.block(Mono.java:1779)\n\tat
com.azure.storage.blob.specialized.BlobClientBase.openInputStream(BlobClientBase.java:393)\n\tat
com.azure.storage.blob.specialized.BlobClientBase.openInputStream(BlobClientBase.java:323)\n\tat
com.azure.storage.blob.specialized.BlobClientBase.openInputStream(BlobClientBase.java:312) \n\tat
com.azure.storage.blob.specialized.BlobClientBase.openInputStream(BlobClientBase.java:299)\n

Пожалуйста, помогите мне отключиться от эта проблема

Подробнее здесь: https://stackoverflow.com/questions/793 ... lexception