From 5452fd1ce438a8c5cedcf689c86090169e5bd884 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Botond=20D=C3=A9nes?= Date: Wed, 19 Jul 2023 02:38:41 -0400 Subject: [PATCH] streaming: opt-in to compacting the stream Use locally generated compaction time on each node. This could lead to different nodes making different decisions on what is expired or not. But this is already the case for streaming, as what exactly is expired depends on when compaction last run. --- streaming/stream_transfer_task.cc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streaming/stream_transfer_task.cc b/streaming/stream_transfer_task.cc index fc0698d4f0..1755cdb043 100644 --- a/streaming/stream_transfer_task.cc +++ b/streaming/stream_transfer_task.cc @@ -70,7 +70,7 @@ struct send_info { , cf(tbl_) , ranges(std::move(ranges_)) , prs(dht::to_partition_ranges(ranges)) - , reader(cf.make_streaming_reader(cf.schema(), std::move(permit_), prs, {})) + , reader(cf.make_streaming_reader(cf.schema(), std::move(permit_), prs, gc_clock::now())) , update(std::move(update_fn)) { }