Skip to content

Commit 9a5df0c

Browse files
author
Devdutt Shenoi
committed
fix: parquet name
1 parent 1d81762 commit 9a5df0c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/parseable/streams.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ fn arrow_path_to_parquet(path: &Path, random_string: &str) -> Option<PathBuf> {
7272
let filename = path.file_stem()?.to_str()?;
7373
let (_, front) = filename.split_once('.')?;
7474
assert!(front.contains('.'), "contains the delim `.`");
75-
let filename_with_random_number = format!("{front}.data.{random_string}.parquet");
75+
let filename_with_random_number = format!("{front}.{random_string}.parquet");
7676
let mut parquet_path = path.to_owned();
7777
parquet_path.set_file_name(filename_with_random_number);
7878

0 commit comments

Comments
 (0)