[BUG] java.lang.IllegalStateException: block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-epoll-1, when using uploadWithResponse method of BlobClient

[RichaNegi]

[BUG] java.lang.IllegalStateException: block()/blockFirst()/blockLast() are blocking, which is not supported in thread reactor-http-epoll-1, when using uploadWithResponse method of BlobClient

[alzimmermsft]

@ibrahimrabab when release is done this month can you update this issue with the version containing the fix.

[joshfree]

@alzimmermsft could you help Storage by taking a first look at this?

/cc @ibrahimrabab

[alzimmermsft]

Thanks for reporting this @RichaNegi

This issue appears due to the InputStream returned by the BlobClient blocking downloads from the service but when the InputStream is passed to the upload method the stream is converted from InputStream to Flux<ByteBuffer> due to the sync-over-async nature of the Storage SDKs.

For now, I'll work with you on a workaround for this. Is there a reason that this code pattern is used rather than the Copy Blob REST API?

[bferrenq]

Hello @alzimmermsft ,
and thank you for your feedback and proposal.
Rational on our side for such use case is our framework is doing streaming between various source type and destination, like sftp to sftp or sftp to blobstore. In this ticket situation it is blob to blob.
We could potentially update our code to use "copy" instead of "uploadWithResponse", can you please tell us if behind the scene it would bring some optimizations or any additional benefits, or would it only fix this issue?

[baiglin]

Hi @alzimmermsft where can we check the new version delivered from that change?