Skip to content

Commit c3bc033

Browse files
committed
fix
1 parent 8fa7d7c commit c3bc033

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

riffle-server/src/app_manager/app.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -539,10 +539,7 @@ mod tests {
539539
let app_id = ApplicationId::YARN(1, 1, 1);
540540

541541
let mut hmap = HashMap::new();
542-
hmap.insert(
543-
"spark.rss.riffle.storageCapacityPartitionSplitEnabled".to_string(),
544-
"true".to_string(),
545-
);
542+
hmap.insert(HARD_SPLIT_ENABLED.get_key(), "true".to_string());
546543
let conf = ClientRssConf::from(hmap);
547544
let options = AppConfigOptions::new(DataDistribution::NORMAL, 1, None, conf);
548545

riffle-server/src/client_configs.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,10 @@ impl<T: Clone + Send + Sync + 'static> ClientConfigOption<T> {
9696
self.description = Some(desc.to_string());
9797
self
9898
}
99+
100+
pub fn get_key(&self) -> String {
101+
self.key.clone()
102+
}
99103
}
100104
#[cfg(test)]
101105
mod tests {

0 commit comments

Comments
 (0)