Fix bug: Try optimize empty parts. #313

pingcap · Nov 4, 2019 · 5f1e330 · 5f1e330
1 parent 117656a
commit 5f1e330
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/dbms/src/DataStreams/ReplacingTMTSortedBlockInputStream.cpp b/dbms/src/DataStreams/ReplacingTMTSortedBlockInputStream.cpp
@@ -120,10 +120,13 @@ void ReplacingTMTSortedBlockInputStream<HandleType>::merge(MutableColumns & merg
         }
     }
 
-    if (isDefiniteDeleted())
-        ++deleted_by_range;
-    else if (!(final && hasDeleteFlag() && behindGcTso()))
-        insertRow(merged_columns, merged_rows);
+    if (!selected_row.empty())
+    {
+        if (isDefiniteDeleted())
+            ++deleted_by_range;
+        else if (!(final && hasDeleteFlag() && behindGcTso()))
+            insertRow(merged_columns, merged_rows);
+    }
 
     finished = true;
 }