Skip to content

Commit de65af8

Browse files
add random suffix to table name
1 parent 43926be commit de65af8

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/storage/object_storage.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -975,8 +975,9 @@ async fn calculate_field_stats(
975975
.expect("only parquet files are returned by iterator")
976976
.to_str()
977977
.expect("filename is valid string");
978+
let random_suffix = Ulid::new().to_string();
978979
let parquet_file_name = str::replace(parquet_file_name, ".", "_");
979-
let ctx_table_name = format!("{}_{}", stream_name, parquet_file_name);
980+
let ctx_table_name = format!("{}_{}_{}", stream_name, parquet_file_name, random_suffix);
980981
ctx.register_parquet(
981982
&ctx_table_name,
982983
parquet_path.to_str().expect("valid path"),

0 commit comments

Comments
 (0)