We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2783378 commit 1660104Copy full SHA for 1660104
src/common/storage/src/stage.rs
@@ -24,7 +24,6 @@ use databend_common_exception::Result;
24
use databend_common_meta_app::principal::StageInfo;
25
use databend_common_meta_app::principal::StageType;
26
use databend_common_meta_app::principal::UserIdentity;
27
-use databend_common_meta_app::principal::COPY_MAX_FILES_PER_COMMIT;
28
use futures::stream;
29
use futures::Stream;
30
use futures::StreamExt;
@@ -157,7 +156,8 @@ impl StageFilesInfo {
157
156
operator,
158
&self.path,
159
pattern,
160
- max_files.unwrap_or(COPY_MAX_FILES_PER_COMMIT),
+ // TODO(youngsofun): after select-from-stage and list-stage use list_stream, we will force caller to provide max_files here.
+ max_files.unwrap_or(usize::MAX),
161
)
162
.await
163
}
0 commit comments