We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 89edfc8 commit a516cc0Copy full SHA for a516cc0
src/parseable/streams.rs
@@ -144,6 +144,7 @@ impl Stream {
144
// entry is not present thus we create it
145
std::fs::create_dir_all(&self.data_path)?;
146
147
+ // Use current time for partitioning to ensure consistent partition boundaries
148
let range =
149
TimeRange::granularity_range(Utc::now(), OBJECT_STORE_DATA_GRANULARITY);
150
let file_path = self.data_path.join(&filename);
0 commit comments