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 8706176 commit cce0cb6Copy full SHA for cce0cb6
src/parseable/staging/writer.rs
@@ -30,7 +30,7 @@ use arrow_ipc::writer::StreamWriter;
30
use arrow_schema::Schema;
31
use arrow_select::concat::concat_batches;
32
use itertools::Itertools;
33
-use tracing::error;
+use tracing::{error, warn};
34
35
use crate::{
36
parseable::{ARROW_FILE_EXTENSION, PART_FILE_EXTENSION},
@@ -81,6 +81,11 @@ impl Drop for DiskWriter {
81
82
let mut arrow_path = self.path.to_owned();
83
arrow_path.set_extension(ARROW_FILE_EXTENSION);
84
+
85
+ if arrow_path.exists() {
86
+ warn!("File {arrow_path:?} exists and will be overwritten");
87
+ }
88
89
if let Err(err) = std::fs::rename(&self.path, &arrow_path) {
90
error!("Couldn't rename file {:?}, error = {err}", self.path);
91
}
0 commit comments