IT WORKSSSSSSSS

vanzin · Jan 10, 2019 · c91574d · c91574d
1 parent cffc20c
commit c91574d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/core/src/main/java/org/apache/spark/shuffle/external/ExternalShuffleIndexWriter.java b/core/src/main/java/org/apache/spark/shuffle/external/ExternalShuffleIndexWriter.java
@@ -53,8 +53,7 @@ public void onFailure(Throwable e) {
         TransportClient client = null;
         try {
             logger.info("Committing all partitions with a creation of an index file");
-            logger.info("Partition Lengths: " + partitionLengths.length + ": "
-                    + partitionLengths[0] + "," + partitionLengths[1]);
+            logger.info("Partition Lengths: " + partitionLengths.length);
             ByteBuffer streamHeader = new UploadShuffleIndexStream(
                 appId, shuffleId, mapId).toByteBuffer();
             // Size includes first 0L offset

diff --git a/core/src/main/java/org/apache/spark/shuffle/external/ExternalShuffleMapOutputWriter.java b/core/src/main/java/org/apache/spark/shuffle/external/ExternalShuffleMapOutputWriter.java
@@ -62,7 +62,7 @@ public void commitAllPartitions(long[] partitionLengths) {
     @Override
     public void abort(Exception exception) {
         clientFactory.close();
-        logger.error("Encountered error while" +
+        logger.error("Encountered error while " +
                 "attempting to add partitions to ESS", exception);
     }
 }