File tree Expand file tree Collapse file tree 2 files changed +3
-5
lines changed Expand file tree Collapse file tree 2 files changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -721,10 +721,8 @@ impl Stream {
721
721
match std:: fs:: File :: open ( path) {
722
722
Ok ( file) => match SerializedFileReader :: new ( file) {
723
723
Ok ( reader) => {
724
- if reader. metadata ( ) . file_metadata ( ) . num_rows ( ) < 0 {
725
- error ! (
726
- "Invalid row count in parquet file {path:?} for stream {stream_name}"
727
- ) ;
724
+ if reader. metadata ( ) . file_metadata ( ) . num_rows ( ) == 0 {
725
+ error ! ( "Invalid parquet file {path:?} for stream {stream_name}" ) ;
728
726
false
729
727
} else {
730
728
true
Original file line number Diff line number Diff line change @@ -138,7 +138,7 @@ async fn upload_single_parquet_file(
138
138
error ! ( "Upload size validation failed for file {filename:?}, deleted from object storage" ) ;
139
139
return Ok ( UploadResult {
140
140
file_path : path,
141
- manifest_file : None , // This will trigger local file cleanup
141
+ manifest_file : None , // Preserve staging file for retry; no manifest created
142
142
} ) ;
143
143
}
144
144
You can’t perform that action at this time.
0 commit comments