File tree 2 files changed +5
-3
lines changed
2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -543,7 +543,6 @@ pub(super) async fn list_log_files(
543
543
let mut commit_files = Vec :: with_capacity ( 25 ) ;
544
544
let mut checkpoint_files = Vec :: with_capacity ( 10 ) ;
545
545
546
-
547
546
// QUESTION: Does this need to be filtered to exclude subdirs?
548
547
for meta in fs_client
549
548
. list_with_offset ( Some ( log_root) , & start_from)
Original file line number Diff line number Diff line change @@ -6,7 +6,7 @@ use std::time::SystemTime;
6
6
#[ tokio:: test]
7
7
async fn time_travel_by_ds ( ) {
8
8
// test time travel on a table with an uncommited delta in a .tmp subfolder
9
-
9
+
10
10
// git does not preserve mtime, so we need to manually set it in the test
11
11
let log_dir = "../test/tests/data/simple_table/_delta_log" ;
12
12
let log_mtime_pair = vec ! [
@@ -16,7 +16,10 @@ async fn time_travel_by_ds() {
16
16
( "00000000000000000003.json" , "2020-05-04T22:47:31-07:00" ) ,
17
17
( "00000000000000000004.json" , "2020-05-05T22:47:31-07:00" ) ,
18
18
// Final file is uncommitted by Spark and is in a .tmp subdir
19
- ( ".tmp/00000000000000000005.json" , "2020-05-06T22:47:31-07:00" ) ,
19
+ (
20
+ ".tmp/00000000000000000005.json" ,
21
+ "2020-05-06T22:47:31-07:00" ,
22
+ ) ,
20
23
] ;
21
24
for ( fname, ds) in log_mtime_pair {
22
25
let ts: SystemTime = ds_to_ts ( ds) . into ( ) ;
You can’t perform that action at this time.
0 commit comments