fix code sytle

apache · Aug 28, 2023 · 1a3a113 · 1a3a113
1 parent 4344159
commit 1a3a113
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 7 deletions.
diff --git a/...ommon/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java b/...ommon/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java
@@ -147,7 +147,12 @@ public void close() {
   }
 
   public void moveToNextPartitionIfPossible(long endedStreamId) {
-    logger.debug("this:{}, moveToNextPartitionIfPossible endedStreamId: {}, currentLocationIndex: {}, currentSteamId:{}", this, endedStreamId, currentLocationIndex, streamId);
+    logger.debug(
+        "this:{}, moveToNextPartitionIfPossible endedStreamId: {}, currentLocationIndex: {}, currentSteamId:{}",
+        this,
+        endedStreamId,
+        currentLocationIndex,
+        streamId);
     if (currentLocationIndex > 0) {
       if (endedStreamId == streamId) {
         logger.debug("Get end streamId {}", endedStreamId);

diff --git a/...mon/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java b/...mon/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java
@@ -151,7 +151,11 @@ public CelebornBufferStream readBufferedPartition(
       PartitionLocation[] partitionLocations =
           fileGroups.partitionGroups.get(partitionId).toArray(new PartitionLocation[0]);
       Arrays.sort(partitionLocations, Comparator.comparingInt(PartitionLocation::getEpoch));
-      logger.debug("readBufferedPartition shuffleKey:{} partitionid:{} partitionLocation:{}", shuffleKey, partitionId, partitionLocations);
+      logger.debug(
+          "readBufferedPartition shuffleKey:{} partitionid:{} partitionLocation:{}",
+          shuffleKey,
+          partitionId,
+          partitionLocations);
       return CelebornBufferStream.create(
           this,
           flinkTransportClientFactory,

diff --git a/tests/flink-it/src/test/java/org/apache/celeborn/tests/flink/WordCountHelper.java b/tests/flink-it/src/test/java/org/apache/celeborn/tests/flink/WordCountHelper.java
@@ -97,11 +97,11 @@ public VerifySink(long wordCount) {
 
     @Override
     public void invoke(Long value, Context context) {
-//      try {
-//        Thread.sleep(100 *1000);
-//      } catch (InterruptedException e) {
-//        e.printStackTrace();
-//      }
+      //      try {
+      //        Thread.sleep(100 *1000);
+      //      } catch (InterruptedException e) {
+      //        e.printStackTrace();
+      //      }
       assertEquals(wordCount, value);
     }
   }