Caused by: java.io.EOFException: reached end of stream after skipping 14933328 bytes; 67108864 bytes expected

package org.example;

import com.google.common.collect.ImmutableSet;
import com.google.inject.Module;
import org.jclouds.ContextBuilder;
import org.jclouds.blobstore.BlobStore;
import org.jclouds.blobstore.BlobStoreContext;
import org.jclouds.blobstore.domain.Blob;
import org.jclouds.blobstore.options.PutOptions;
import org.jclouds.logging.slf4j.config.SLF4JLoggingModule;

import java.io.BufferedInputStream;
import java.io.InputStream;
import java.net.Authenticator;
import java.net.PasswordAuthentication;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.Duration;
import java.util.UUID;

public class Main {

    public static void main(String[] args) throws Exception {
        Iterable<Module> modules = ImmutableSet.<Module>of(
                new SLF4JLoggingModule());
        ContextBuilder contextBuilder = ContextBuilder.newBuilder("aws-s3")
                .credentials("<IDENTITY>", "<CREDENTIAL>")
                .modules(modules);
        BlobStoreContext blobStoreContext = contextBuilder.buildView(BlobStoreContext.class);
        BlobStore blobStore = blobStoreContext.getBlobStore();
        String decodedUrl = "<URL>";
        HttpClient client = buildHttpClient(decodedUrl);
        HttpResponse<InputStream> response = callRemoteEndpointWithRetry(client, decodedUrl);
        long fileSize = response.headers()
                .firstValueAsLong("Content-Length")
                .orElseThrow(() -> new IllegalArgumentException("No Content-Length"));
        System.out.println("Bytes: " + fileSize);
        InputStream inputStream = response.body();

            String container = "<CONTAINER>";
            Blob blob = blobStore.blobBuilder("TEST.zip")
//                    .payload(new BufferedInputStream(inputStream, 8 * 1024))
                    .payload(inputStream)
                    .contentDisposition(UUID.randomUUID().toString())
                    .contentType("application/octet-stream")
                    .contentLength(fileSize)
                    .build();
            blobStore.putBlob(container, blob, PutOptions.Builder.multipart());
    }

    private static HttpClient buildHttpClient(String decodedUrl) {
        return HttpClient.newBuilder()
                .version(HttpClient.Version.HTTP_1_1)
                .connectTimeout(Duration.ofMinutes(60))
                .followRedirects(HttpClient.Redirect.NORMAL)
                .authenticator(buildPasswordAuthenticator(decodedUrl))
                .build();
    }

    private static Authenticator buildPasswordAuthenticator(String decodedUrl) {
        return new Authenticator() {
            @Override
            protected PasswordAuthentication getPasswordAuthentication() {
                var uri = URI.create(decodedUrl);
                var userInfo = uri.getUserInfo();
                if (userInfo != null) {
                    var separatorIndex = userInfo.indexOf(':');
                    var username = userInfo.substring(0, separatorIndex);
                    var password = userInfo.substring(separatorIndex + 1);
                    return new PasswordAuthentication(username, password.toCharArray());
                }
                return super.getPasswordAuthentication();
            }
        };
    }

    private static HttpResponse<InputStream> callRemoteEndpointWithRetry(HttpClient client, String decodedUrl) throws Exception {
        var response = client.send(buildFetchFileRequest(decodedUrl), HttpResponse.BodyHandlers.ofInputStream());
        if (response.statusCode() / 100 != 2) {
            throw new IllegalStateException("INVALID CODE " + response.statusCode());
        }
        return response;
    }

    private static HttpRequest buildFetchFileRequest(String decodedUrl) {
        var builder = HttpRequest.newBuilder()
                .GET()
                .expectContinue(true)
                .headers("Content-Type", "multipart/form-data")
                .timeout(Duration.ofMinutes(30));
        var uri = URI.create(decodedUrl);
        var userInfo = uri.getUserInfo();
        if (userInfo != null) {
            builder.uri(URI.create(decodedUrl.replace(userInfo + "@", "")));
        } else {
            builder.uri(uri);
        }
        return builder.build();
    }

}