Skip to content

Commit 065c88d

Browse files
alchemist51bharath-techie
authored andcommitted
Fix Listing Cache
Signed-off-by: Arpit Bandejiya <[email protected]>
1 parent 803fe6a commit 065c88d

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

plugins/engine-datafusion/jni/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ pub extern "system" fn Java_org_opensearch_datafusion_DataFusionQueryJNI_execute
215215

216216
let runtime_env = RuntimeEnvBuilder::new()
217217
.with_cache_manager(CacheManagerConfig::default()
218-
//.with_list_files_cache(Some(list_file_cache)) TODO: //Fix this
218+
.with_list_files_cache(Some(list_file_cache.clone()))
219219
).build().unwrap();
220220

221221
// TODO: get config from CSV DataFormat

plugins/engine-datafusion/jni/src/util.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -168,11 +168,11 @@ pub fn create_object_meta_from_filenames(base_path: &str, filenames: Vec<String>
168168
.unwrap_or_else(|_| Utc::now());
169169

170170
ObjectMeta {
171-
location: ObjectPath::from(filename),
171+
location: ObjectPath::from(full_path),
172172
last_modified: modified,
173173
size: file_size,
174174
e_tag: None,
175175
version: None,
176176
}
177177
}).collect()
178-
}
178+
}

0 commit comments

Comments
 (0)