[incubator-uniffle] branch master updated: Revert "[ISSUE-173][FOLLOWUP] The size of single buffer flush should reach rss.server.flush.cold.storage.threshold.size (#178)" (#179)

[roryqi]

This is an automated email from the ASF dual-hosted git repository.

roryqi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git


The following commit(s) were added to refs/heads/master by this push:
     new e9fd3734 Revert "[ISSUE-173][FOLLOWUP] The size of single buffer flush 
should reach rss.server.flush.cold.storage.threshold.size  (#178)" (#179)
e9fd3734 is described below

commit e9fd373414fe8a9223146efdbd0f0e8d4a2b82c6
Author: roryqi <jerqi1242949...@gmail.com>
AuthorDate: Mon Aug 22 23:34:24 2022 +0800

    Revert "[ISSUE-173][FOLLOWUP] The size of single buffer flush should reach 
rss.server.flush.cold.storage.threshold.size  (#178)" (#179)
    
    This reverts commit ab6be6ed4ab0d8bfe4bbcf26c6597ded28a0c1aa.
---
 .../java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java
 
b/server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java
index 660cd5c5..f934f0f6 100644
--- 
a/server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java
+++ 
b/server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java
@@ -165,9 +165,7 @@ public class ShuffleBufferManager {
 
   void flushSingleBufferIfNecessary(ShuffleBuffer buffer, String appId,
       int shuffleId, int startPartition, int endPartition) {
-    // When we use multistorage and trigger single buffer flush, the buffer 
size should be bigger
-    // than rss.server.flush.cold.storage.threshold.size, otherwise cold 
storage will be useless.
-    if (this.bufferFlushEnabled && buffer.getSize() > 
this.bufferFlushThreshold) {
+    if (this.bufferFlushEnabled && buffer.getSize() >= 
this.bufferFlushThreshold) {
       flushBuffer(buffer, appId, shuffleId, startPartition, endPartition);
     }
   }