Skip to content

Commit 1b17b6b

Browse files
fixes
1 parent 2fbac7f commit 1b17b6b

File tree

3 files changed

+4
-5
lines changed

3 files changed

+4
-5
lines changed

.github/workflows/slo-topic.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,5 +31,5 @@ jobs:
3131
run: |
3232
cd slo/src/TopicService
3333
dotnet run run grpc://localhost:2135 /Root/testdb \
34-
--time 600 \
35-
--write-timeout 1000
34+
--write-rps 100 \
35+
--time 600

slo/src/TopicService/SloTopicContext.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,8 @@ await topicClient.CreateTopic(
4646

4747
public async Task Run(RunConfig config)
4848
{
49+
AppContext.SetSwitch("System.Net.SocketsHttpHandler.Http2FlowControl.DisableDynamicWindowSizing", true);
50+
4951
Logger.LogInformation("Started Run topic slo test");
5052
var driver = await Driver.CreateInitialized(
5153
new DriverConfig(config.Endpoint, config.Db), ISloContext.Factory);

src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -273,9 +273,6 @@ private async Task Initialize()
273273
var copyInFlightMessages = new ConcurrentQueue<MessageSending>();
274274
var lastSeqNo = initResponse.LastSeqNo;
275275

276-
_logger.LogInformation("Writer[{PartitionId}] have lastSeqNo: {lastSeqNo}", _config.PartitionId,
277-
lastSeqNo);
278-
279276
while (_inFlightMessages.TryDequeue(out var sendData))
280277
{
281278
if (lastSeqNo >= sendData.MessageData.SeqNo)

0 commit comments

Comments
 (0)