File tree 1 file changed +14
-2
lines changed
src/query/storages/stage/src/read/row_based/processors
1 file changed +14
-2
lines changed Original file line number Diff line number Diff line change @@ -80,9 +80,21 @@ impl AccumulatingTransform for Decompressor {
80
80
}
81
81
82
82
if let Some ( ( de, offset) ) = & mut self . decompressor {
83
- let mut data = de. decompress_batch ( & batch. data ) ?;
83
+ let mut data = de. decompress_batch ( & batch. data ) . map_err ( |e| {
84
+ if let Some ( p) = & self . path {
85
+ e. add_detail_back ( format ! ( "file path: {p}" ) )
86
+ } else {
87
+ e
88
+ }
89
+ } ) ?;
84
90
if batch. is_eof {
85
- let mut end = de. decompress_batch ( & [ ] ) ?;
91
+ let mut end = de. decompress_batch ( & [ ] ) . map_err ( |e| {
92
+ if let Some ( p) = & self . path {
93
+ e. add_detail_back ( format ! ( "file path: {p}" ) )
94
+ } else {
95
+ e
96
+ }
97
+ } ) ?;
86
98
data. append ( & mut end) ;
87
99
let state = de. state ( ) ;
88
100
if !matches ! ( state, DecompressState :: Done ) {
You can’t perform that action at this time.
0 commit comments