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 fa76d246f5 IGNITE-19728 .NET: Fix TestAutoFlushFrequency flakiness 
(#2189)
fa76d246f5 is described below

commit fa76d246f58a1d12952f4ebda8464f9e5d08c4ac
Author: Pavel Tupitsyn <[email protected]>
AuthorDate: Wed Jun 14 10:42:30 2023 +0300

    IGNITE-19728 .NET: Fix TestAutoFlushFrequency flakiness (#2189)
    
    DataStreamerTests.TestAutoFlushFrequency flakiness, fix 
IgniteClientTests.ToString flakiness.
---
 .../platforms/dotnet/Apache.Ignite.Tests/IgniteClientTests.cs  |  3 ++-
 .../dotnet/Apache.Ignite.Tests/Table/DataStreamerTests.cs      | 10 +++++++++-
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/modules/platforms/dotnet/Apache.Ignite.Tests/IgniteClientTests.cs 
b/modules/platforms/dotnet/Apache.Ignite.Tests/IgniteClientTests.cs
index 3bda69fd75..3db7a71f41 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Tests/IgniteClientTests.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Tests/IgniteClientTests.cs
@@ -49,7 +49,8 @@ namespace Apache.Ignite.Tests
         [Test]
         public async Task TestToString()
         {
-            using var client = await IgniteClient.StartAsync(GetConfig());
+            var cfg = new IgniteClientConfiguration { Endpoints = { 
"127.0.0.1:" + ServerPort } };
+            using var client = await IgniteClient.StartAsync(cfg);
 
             // IgniteClientInternal { Connections = [ ClusterNode {
             // Id = 703cc4d7-41ef-4321-b960-70ad9df2617b,
diff --git 
a/modules/platforms/dotnet/Apache.Ignite.Tests/Table/DataStreamerTests.cs 
b/modules/platforms/dotnet/Apache.Ignite.Tests/Table/DataStreamerTests.cs
index daf3b3f693..ad6fa7cffa 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Tests/Table/DataStreamerTests.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Tests/Table/DataStreamerTests.cs
@@ -100,7 +100,15 @@ public class DataStreamerTests : IgniteTestsBase
 
         await Task.Delay(100);
 
-        Assert.AreEqual(enabled, await TupleView.ContainsKeyAsync(null, 
GetTuple(0)));
+        if (enabled)
+        {
+            TestUtils.WaitForCondition(() => TupleView.ContainsKeyAsync(null, 
GetTuple(0)).GetAwaiter().GetResult());
+        }
+        else
+        {
+            Assert.IsFalse(await TupleView.ContainsKeyAsync(null, 
GetTuple(0)));
+        }
+
         Assert.IsFalse(await TupleView.ContainsKeyAsync(null, GetTuple(1)));
 
         cts.Cancel();

Reply via email to