Fix potential hang issues when fine grained shuffle is enabled (#9548)

ref #9413 Signed-off-by: xufei <[email protected]>
pingcap · Oct 21, 2024 · ba157b4 · ba157b4
1 parent 9eb0c80
commit ba157b4
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/dbms/src/Flash/Mpp/MPPTunnelSetWriter.cpp b/dbms/src/Flash/Mpp/MPPTunnelSetWriter.cpp
@@ -432,9 +432,6 @@ void MPPTunnelSetWriterBase::fineGrainedShuffleWrite(
         compression_method,
         original_size);
 
-    if unlikely (tracked_packet->getPacket().chunks_size() <= 0)
-        return;
-
     auto packet_bytes = tracked_packet->getPacket().ByteSizeLong();
     checkPacketSize(packet_bytes);
     writeToTunnel(std::move(tracked_packet), partition_id);
@@ -457,9 +454,6 @@ void MPPTunnelSetWriterBase::fineGrainedShuffleWrite(
         num_columns,
         result_field_types);
 
-    if unlikely (tracked_packet->getPacket().chunks_size() <= 0)
-        return;
-
     auto packet_bytes = tracked_packet->getPacket().ByteSizeLong();
     checkPacketSize(packet_bytes);
     writeToTunnel(std::move(tracked_packet), partition_id);