fix(tianmu):Even if a primary key is defined, duplicate data may be i…

…mported.(stoneatom#1648)
konghaiya · May 10, 2023 · 902e6bc · 902e6bc
1 parent c95d263
commit 902e6bc
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/storage/tianmu/core/tianmu_table.cpp b/storage/tianmu/core/tianmu_table.cpp
@@ -1601,15 +1601,6 @@ uint64_t TianmuTable::MergeDeltaTable(system::IOParameters &iop) {
       total_read_cnt++;
       total_read_bytes += value.size();
 
-      if (insert_records.size() >= static_cast<std::size_t>(tianmu_sysvar_insert_max_buffered)) {
-        insert_num += AsyncParseInsertRecords(&iop, &insert_records);
-      }
-      if (update_records.size() >= static_cast<std::size_t>(tianmu_sysvar_insert_max_buffered)) {
-        update_num += AsyncParseUpdateRecords(&iop, &update_records);
-      }
-      if (delete_records.size() >= static_cast<std::size_t>(tianmu_sysvar_insert_max_buffered)) {
-        delete_num += AsyncParseDeleteRecords(delete_records);
-      }
       iter->Next();
     }
   }