This is an automated email from the ASF dual-hosted git repository.
ptupitsyn pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 728ab1f9c6 IGNITE-22893 .NET: Fix TestFailedSchemaLoadTaskIsRetried
flakiness (#4173)
728ab1f9c6 is described below
commit 728ab1f9c636679aa526c9b0282e89008b099cb2
Author: Pavel Tupitsyn <[email protected]>
AuthorDate: Mon Aug 5 08:50:43 2024 +0300
IGNITE-22893 .NET: Fix TestFailedSchemaLoadTaskIsRetried flakiness (#4173)
Test seems to fail due to automatic reconnect triggered with a heartbeat in
background.
* Enable logging
* Increase heartbeat timeout
* Fail heartbeats in FakeServer
---
.../dotnet/Apache.Ignite.Tests/Table/SchemaUpdateTest.cs | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
diff --git
a/modules/platforms/dotnet/Apache.Ignite.Tests/Table/SchemaUpdateTest.cs
b/modules/platforms/dotnet/Apache.Ignite.Tests/Table/SchemaUpdateTest.cs
index 2c4eec63b5..2dd8fc43ca 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Tests/Table/SchemaUpdateTest.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Tests/Table/SchemaUpdateTest.cs
@@ -24,6 +24,7 @@ using System.Threading.Tasks;
using Ignite.Table;
using Internal.Proto;
using Internal.Table;
+using Microsoft.Extensions.Logging;
using NUnit.Framework;
/// <summary>
@@ -62,11 +63,17 @@ public class SchemaUpdateTest
[Test]
public async Task TestFailedSchemaLoadTaskIsRetried()
{
- using var server = new FakeServer(shouldDropConnection: ctx => ctx is
{ OpCode: ClientOp.SchemasGet, RequestCount: < 3 });
+ using var server = new FakeServer(shouldDropConnection: ctx => ctx is
+ {
+ OpCode: ClientOp.SchemasGet or ClientOp.Heartbeat,
+ RequestCount: < 3
+ });
var cfg = new IgniteClientConfiguration
{
- RetryPolicy = new RetryNonePolicy()
+ RetryPolicy = new RetryNonePolicy(),
+ LoggerFactory = TestUtils.GetConsoleLoggerFactory(LogLevel.Trace),
+ HeartbeatInterval = TimeSpan.FromDays(1)
};
using var client = await server.ConnectClientAsync(cfg);