1
- use std:: collections:: HashSet ;
2
1
// Copyright 2022 Datafuse Labs.
3
2
//
4
3
// Licensed under the Apache License, Version 2.0 (the "License");
@@ -12,6 +11,7 @@ use std::collections::HashSet;
12
11
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
12
// See the License for the specific language governing permissions and
14
13
// limitations under the License.
14
+ use std:: collections:: HashSet ;
15
15
use std:: path:: Path ;
16
16
use std:: sync:: Arc ;
17
17
@@ -65,8 +65,6 @@ impl CopyInterpreterV2 {
65
65
match & from. source_info {
66
66
SourceInfo :: StageSource ( table_info) => {
67
67
let path = & table_info. path ;
68
- tracing:: info!( "path is :{}" , path) ;
69
-
70
68
// Here we add the path to the file: /path/to/path/file1.
71
69
let files_with_path = if !files. is_empty ( ) {
72
70
let mut files_with_path = vec ! [ ] ;
@@ -76,7 +74,6 @@ impl CopyInterpreterV2 {
76
74
}
77
75
files_with_path
78
76
} else if !path. ends_with ( '/' ) {
79
- tracing:: info!( "path not ends with '/'" ) ;
80
77
let rename_me: Arc < dyn TableContext > = self . ctx . clone ( ) ;
81
78
let op = StageSourceHelper :: get_op ( & rename_me, & table_info. stage_info ) . await ?;
82
79
if op. object ( path) . is_exist ( ) . await ? {
@@ -85,7 +82,6 @@ impl CopyInterpreterV2 {
85
82
vec ! [ ]
86
83
}
87
84
} else {
88
- tracing:: info!( "shit" ) ;
89
85
let rename_me: Arc < dyn TableContext > = self . ctx . clone ( ) ;
90
86
let op = StageSourceHelper :: get_op ( & rename_me, & table_info. stage_info ) . await ?;
91
87
@@ -95,13 +91,10 @@ impl CopyInterpreterV2 {
95
91
96
92
// TODO: we could rewrite into try_collect.
97
93
let mut objects = op. batch ( ) . walk_top_down ( path) ?;
98
- tracing:: info!( "common here we go top down" ) ;
99
94
while let Some ( de) = objects. try_next ( ) . await ? {
100
95
if de. mode ( ) . is_dir ( ) {
101
- tracing:: info!( "dir continue" ) ;
102
96
continue ;
103
97
}
104
- tracing:: info!( "insert path to list" ) ;
105
98
list. insert ( de. path ( ) . to_string ( ) ) ;
106
99
}
107
100
@@ -310,10 +303,6 @@ impl Interpreter for CopyInterpreterV2 {
310
303
311
304
// Pattern match check.
312
305
let pattern = & pattern;
313
- tracing:: info!(
314
- "parttern should be empty right, tell me, it is {}" ,
315
- pattern. is_empty( )
316
- ) ;
317
306
if !pattern. is_empty ( ) {
318
307
let regex = Regex :: new ( pattern) . map_err ( |e| {
319
308
ErrorCode :: SyntaxException ( format ! (
0 commit comments