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();