aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhor911 <hor911@ydb.tech>2022-11-22 01:19:56 +0300
committerhor911 <hor911@ydb.tech>2022-11-22 01:19:56 +0300
commit1060914f94b4c25e526e41adaa68518a8932e583 (patch)
tree3781f42f62957585c674ce4050e2c44681a8bffc
parent3053b9a4c1d6a0c2f708caf5e62616cb666ec995 (diff)
downloadydb-1060914f94b4c25e526e41adaa68518a8932e583.tar.gz
Correct inflight defaults
-rw-r--r--ydb/core/yq/libs/config/protos/read_actors_factory.proto2
-rw-r--r--ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h2
2 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/yq/libs/config/protos/read_actors_factory.proto b/ydb/core/yq/libs/config/protos/read_actors_factory.proto
index ab5de69f82d..77082725301 100644
--- a/ydb/core/yq/libs/config/protos/read_actors_factory.proto
+++ b/ydb/core/yq/libs/config/protos/read_actors_factory.proto
@@ -11,7 +11,7 @@ import "ydb/library/yql/providers/s3/proto/retry_config.proto";
message TS3ReadActorFactoryConfig {
NYql.NS3.TRetryConfig RetryConfig = 1;
uint64 RowsInBatch = 2; // Default = 1000
- uint64 MaxInflight = 3; // Default = 10
+ uint64 MaxInflight = 3; // Default = 20
}
message TPqReadActorFactoryConfig {
diff --git a/ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h b/ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h
index bf6c6c7eab5..8f78895a4e3 100644
--- a/ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h
+++ b/ydb/library/yql/providers/s3/actors/yql_s3_source_factory.h
@@ -13,7 +13,7 @@ namespace NYql::NDq {
struct TS3ReadActorFactoryConfig {
ui64 RowsInBatch = 1000;
- ui64 MaxInflight = 1000;
+ ui64 MaxInflight = 20;
};
void RegisterS3ReadActorFactory(