[SKIP AFTER 4.5] Backport a4053db

Attempt at reduce number of sstables during repair
criteo-forks · Sep 27, 2021 · 4b9cfb9 · 4b9cfb9
1 parent 94895ce
commit 4b9cfb9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/repair/row_level.cc b/repair/row_level.cc
@@ -580,8 +580,8 @@ class repair_writer : public enable_lw_shared_from_this<repair_writer> {
                 auto metadata = mutation_source_metadata{};
                 auto& cs = t->get_compaction_strategy();
                 const auto adjusted_estimated_partitions = cs.adjust_partition_estimate(metadata, estimated_partitions);
-                auto consumer = cs.make_interposer_consumer(metadata,
-                        [t = std::move(t), use_view_update_path, adjusted_estimated_partitions] (flat_mutation_reader reader) {
+
+                auto consumer = [t = std::move(t), use_view_update_path, adjusted_estimated_partitions] (flat_mutation_reader reader) {
                     sstables::shared_sstable sst = use_view_update_path ? t->make_streaming_staging_sstable() : t->make_streaming_sstable_for_write();
                     schema_ptr s = reader.schema();
                     auto& pc = service::get_local_streaming_priority();
@@ -597,7 +597,7 @@ class repair_writer : public enable_lw_shared_from_this<repair_writer> {
                         }
                         return _view_update_generator->local().register_staging_sstable(sst, std::move(t));
                     });
-                });
+                };
                 return consumer(std::move(reader));
             });
         },