From 889a6594f1fd2428483bfe47cc02ca45819c17e7 Mon Sep 17 00:00:00 2001 From: Ryan Moore Date: Fri, 14 Oct 2016 15:00:34 -0600 Subject: [PATCH] Modifying when the maxUploadSize property is set on the bulk put job --- .../ds3client/helpers/Ds3ClientHelpersImpl.java | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/ds3-sdk/src/main/java/com/spectralogic/ds3client/helpers/Ds3ClientHelpersImpl.java b/ds3-sdk/src/main/java/com/spectralogic/ds3client/helpers/Ds3ClientHelpersImpl.java index a5243f51c..7fd80732c 100644 --- a/ds3-sdk/src/main/java/com/spectralogic/ds3client/helpers/Ds3ClientHelpersImpl.java +++ b/ds3-sdk/src/main/java/com/spectralogic/ds3client/helpers/Ds3ClientHelpersImpl.java @@ -108,12 +108,19 @@ private Ds3ClientHelpers.Job innerStartWriteJob(final String bucket, final Iterable objectsToWrite, final WriteJobOptions options) throws IOException { - final PutBulkJobSpectraS3Response prime = this.client.putBulkJobSpectraS3( - new PutBulkJobSpectraS3Request(bucket, Lists.newArrayList(objectsToWrite)) + final PutBulkJobSpectraS3Request request = new PutBulkJobSpectraS3Request(bucket, Lists.newArrayList(objectsToWrite)) .withPriority(options.getPriority()) - .withMaxUploadSize(options.getMaxUploadSize()) .withAggregating(options.isAggregating()) - .withIgnoreNamingConflicts(options.doIgnoreNamingConflicts())); + .withIgnoreNamingConflicts(options.doIgnoreNamingConflicts()); + + if (options.getMaxUploadSize() > 0) { + request.withMaxUploadSize(options.getMaxUploadSize()); + } + + final PutBulkJobSpectraS3Response prime = this.client.putBulkJobSpectraS3( + request); + + return new WriteJobImpl( this.client, prime.getResult(),