@@ -27,7 +27,6 @@ use common_ast::parser::parse_comma_separated_exprs;
27
27
use common_ast:: parser:: tokenize_sql;
28
28
use common_ast:: Backtrace ;
29
29
use common_base:: runtime:: GlobalIORuntime ;
30
- use common_catalog:: plan:: StageFileStatus ;
31
30
use common_catalog:: plan:: StageTableInfo ;
32
31
use common_catalog:: table:: AppendMode ;
33
32
use common_catalog:: table_context:: StageAttachment ;
@@ -212,25 +211,13 @@ impl InsertInterpreterV2 {
212
211
213
212
// TODO:(everpcpc) color_copied_files
214
213
215
- let mut need_copied_file_infos = vec ! [ ] ;
216
- for file in & all_source_file_infos {
217
- if file. status == StageFileStatus :: NeedCopy {
218
- need_copied_file_infos. push ( file. clone ( ) ) ;
219
- }
220
- }
221
-
222
214
tracing:: info!(
223
- "insert: read all stage attachment files finished, all:{}, need copy: {}, elapsed:{}" ,
215
+ "insert: read all stage attachment files finished: {}, elapsed:{}" ,
224
216
all_source_file_infos. len( ) ,
225
- need_copied_file_infos. len( ) ,
226
217
start. elapsed( ) . as_secs( )
227
218
) ;
228
219
229
- if need_copied_file_infos. is_empty ( ) {
230
- return Ok ( ( ) ) ;
231
- }
232
-
233
- stage_table_info. files_to_copy = Some ( need_copied_file_infos. clone ( ) ) ;
220
+ stage_table_info. files_to_copy = Some ( all_source_file_infos. clone ( ) ) ;
234
221
let stage_table = StageTable :: try_create ( stage_table_info. clone ( ) ) ?;
235
222
let read_source_plan = {
236
223
stage_table
0 commit comments