@@ -163,18 +163,15 @@ impl CopyInterpreterV2 {
163
163
match & from. source_info {
164
164
SourceInfo :: StageSource ( table_info) => {
165
165
let path = & table_info. path ;
166
- tracing:: debug!( "list files under path: {}" , path) ;
167
166
// Here we add the path to the file: /path/to/path/file1.
168
167
let files_with_path = if !files. is_empty ( ) {
169
- tracing:: trace!( "got files offered in list" ) ;
170
168
let mut files_with_path = vec ! [ ] ;
171
169
for file in files {
172
170
let new_path = Path :: new ( path) . join ( file) ;
173
171
files_with_path. push ( new_path. to_string_lossy ( ) . to_string ( ) ) ;
174
172
}
175
173
files_with_path
176
174
} else if !path. ends_with ( '/' ) {
177
- tracing:: trace!( "path not ends with '/'" ) ;
178
175
let rename_me: Arc < dyn TableContext > = self . ctx . clone ( ) ;
179
176
let op = StageSourceHelper :: get_op ( & rename_me, & table_info. stage_info ) . await ?;
180
177
if op. object ( path) . is_exist ( ) . await ? {
@@ -183,7 +180,6 @@ impl CopyInterpreterV2 {
183
180
vec ! [ ]
184
181
}
185
182
} else {
186
- tracing:: trace!( "have to list directories in stage" ) ;
187
183
let rename_me: Arc < dyn TableContext > = self . ctx . clone ( ) ;
188
184
let op = StageSourceHelper :: get_op ( & rename_me, & table_info. stage_info ) . await ?;
189
185
@@ -195,10 +191,8 @@ impl CopyInterpreterV2 {
195
191
let mut objects = op. batch ( ) . walk_top_down ( path) ?;
196
192
while let Some ( de) = objects. try_next ( ) . await ? {
197
193
if de. mode ( ) . is_dir ( ) {
198
- tracing:: trace!( "listing in stage path:{} got directory: {}" , path, de. path( ) ) ;
199
194
continue ;
200
195
}
201
- tracing:: trace!( "listing in stage path:{} got file: {}" , path, de. path( ) ) ;
202
196
list. insert ( de. path ( ) . to_string ( ) ) ;
203
197
}
204
198
0 commit comments