Skip to content

Commit beec0e0

Browse files
committed
Finally
1 parent 0bb791c commit beec0e0

File tree

2 files changed

+1
-16
lines changed

2 files changed

+1
-16
lines changed

src/Ydb.Sdk/src/Ado/YdbConnection.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ public IBulkUpsertImporter BeginBulkUpsertImport(
6565
var database = ConnectionStringBuilder.Database.TrimEnd('/');
6666
var tablePath = string.IsNullOrEmpty(database) ? name : $"{database}/{name}";
6767

68-
var maxBytes = ConnectionStringBuilder.BulkUpsertMaxBytes;
68+
var maxBytes = ConnectionStringBuilder.MaxSendMessageSize;
6969

7070
return new BulkUpsertImporter(Session.Driver, tablePath, columns, maxBytes, cancellationToken);
7171
}

src/Ydb.Sdk/src/Ado/YdbConnectionStringBuilder.cs

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ private void InitDefaultValues()
4242
_maxReceiveMessageSize = GrpcDefaultSettings.MaxReceiveMessageSize;
4343
_disableDiscovery = GrpcDefaultSettings.DisableDiscovery;
4444
_disableServerBalancer = false;
45-
_bulkUpsertMaxBytes = 64 * 1024 * 1024;
4645
}
4746

4847
public string Host
@@ -292,20 +291,6 @@ public int MaxReceiveMessageSize
292291
}
293292

294293
private int _maxReceiveMessageSize;
295-
296-
private int _bulkUpsertMaxBytes;
297-
298-
public int BulkUpsertMaxBytes
299-
{
300-
get => _bulkUpsertMaxBytes;
301-
set
302-
{
303-
if (value <= 0)
304-
throw new ArgumentOutOfRangeException(nameof(value), value, "BulkUpsertMaxBytes must be positive.");
305-
_bulkUpsertMaxBytes = value;
306-
SaveValue(nameof(BulkUpsertMaxBytes), value);
307-
}
308-
}
309294

310295
public bool DisableServerBalancer
311296
{

0 commit comments

Comments
 (0)