File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -909,7 +909,7 @@ mod tests {
909
909
) ;
910
910
911
911
let expected_path = staging. data_path . join ( format ! (
912
- "{stream_hash}.date={}.hour={:02}.minute={}.{}.data.{ARROW_FILE_EXTENSION} " ,
912
+ "{stream_hash}.date={}.hour={:02}.minute={}.{}.data.part " ,
913
913
parsed_timestamp. date( ) ,
914
914
parsed_timestamp. hour( ) ,
915
915
minute_to_slot( parsed_timestamp. minute( ) , OBJECT_STORE_DATA_GRANULARITY ) . unwrap( ) ,
@@ -943,7 +943,7 @@ mod tests {
943
943
) ;
944
944
945
945
let expected_path = staging. data_path . join ( format ! (
946
- "{stream_hash}.date={}.hour={:02}.minute={}.key1=value1.key2=value2.{}.data.{ARROW_FILE_EXTENSION} " ,
946
+ "{stream_hash}.date={}.hour={:02}.minute={}.key1=value1.key2=value2.{}.data.part " ,
947
947
parsed_timestamp. date( ) ,
948
948
parsed_timestamp. hour( ) ,
949
949
minute_to_slot( parsed_timestamp. minute( ) , OBJECT_STORE_DATA_GRANULARITY ) . unwrap( ) ,
You can’t perform that action at this time.
0 commit comments