File tree Expand file tree Collapse file tree 1 file changed +14
-2
lines changed
src/query/storages/stage/src/read/row_based/processors Expand file tree Collapse file tree 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 {
8080 }
8181
8282 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+ } ) ?;
8490 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+ } ) ?;
8698 data. append ( & mut end) ;
8799 let state = de. state ( ) ;
88100 if !matches ! ( state, DecompressState :: Done ) {
You can’t perform that action at this time.
0 commit comments