diff --git a/src/main/java/io/github/jpmorganchase/fusion/api/operations/FusionAPIUploadOperations.java b/src/main/java/io/github/jpmorganchase/fusion/api/operations/FusionAPIUploadOperations.java
index 20acba6..5d0f543 100644
--- a/src/main/java/io/github/jpmorganchase/fusion/api/operations/FusionAPIUploadOperations.java
+++ b/src/main/java/io/github/jpmorganchase/fusion/api/operations/FusionAPIUploadOperations.java
@@ -40,7 +40,8 @@
 @Getter
 public class FusionAPIUploadOperations implements APIUploadOperations {
 
-    private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
+    private static final Logger logger =
+            LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
 
     private static final String UPLOAD_FAILED_EXCEPTION_MSG =
             "Exception encountered while attempting to upload part, please try again";
@@ -219,7 +220,6 @@ protected MultipartTransferContext callAPIToUploadParts(MultipartTransferContext
         int chunkSize = uploadPartSize * (1024 * 1024);
         long maxInFluxBytes = maxInFluxDataSize * (1024L * 1024L);
 
-
         byte[] buffer = new byte[chunkSize];
         int partCnt = 1;
         int totalBytes = 0;
@@ -232,7 +232,8 @@ protected MultipartTransferContext callAPIToUploadParts(MultipartTransferContext
             int bytesRead;
             while ((bytesRead = ur.getData().read(buffer)) != -1) {
 
-                logger.debug("Creating upload task for part number {}, bytes read for this part {}", partCnt, bytesRead);
+                logger.debug(
+                        "Creating upload task for part number {}, bytes read for this part {}", partCnt, bytesRead);
 
                 final int currentPartCnt = partCnt;
                 final int currentBytesRead = bytesRead;
@@ -264,7 +265,8 @@ protected MultipartTransferContext callAPIToUploadParts(MultipartTransferContext
         return mtx.transferred(chunkSize, totalBytes, partCnt);
     }
 
-    private int easeDataPressure(List<CompletableFuture<Void>> futures) throws InterruptedException, ExecutionException {
+    private int easeDataPressure(List<CompletableFuture<Void>> futures)
+            throws InterruptedException, ExecutionException {
 
         logger.debug("Reached max in-flux bytes - easing pressure");
         for (CompletableFuture<Void> future : futures) {