File tree Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Expand file tree Collapse file tree 2 files changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -10,6 +10,7 @@ use common::{
10
10
ComponentPath ,
11
11
} ,
12
12
fastrace_helpers:: get_sampled_span,
13
+ knobs:: EXPORT_WORKER_PAGE_SIZE ,
13
14
persistence:: LatestDocument ,
14
15
runtime:: Runtime ,
15
16
types:: {
@@ -146,7 +147,10 @@ where
146
147
) ;
147
148
}
148
149
}
149
- let table_iterator = worker. database . table_iterator ( ts, 1000 ) . multi ( tablet_ids) ;
150
+ let table_iterator = worker
151
+ . database
152
+ . table_iterator ( ts, * EXPORT_WORKER_PAGE_SIZE )
153
+ . multi ( tablet_ids) ;
150
154
151
155
let zipper = construct_zip_snapshot (
152
156
worker,
Original file line number Diff line number Diff line change @@ -1298,6 +1298,10 @@ pub static EXPORT_MAX_INFLIGHT_PREFETCH_BYTES: LazyLock<usize> = LazyLock::new(|
1298
1298
. clamp ( 1 , u32:: MAX as usize )
1299
1299
} ) ;
1300
1300
1301
+ /// The page size to the table iterator in the export worker.
1302
+ pub static EXPORT_WORKER_PAGE_SIZE : LazyLock < usize > =
1303
+ LazyLock :: new ( || env_config ( "EXPORT_WORKER_PAGE_SIZE" , 1000 ) ) ;
1304
+
1301
1305
/// Whether or not a service should propagate all upstream traces or perform its
1302
1306
/// own sampling
1303
1307
pub static PROPAGATE_UPSTREAM_TRACES : LazyLock < bool > =
You can’t perform that action at this time.
0 commit comments