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(),