[jira] [Updated] (IGNITE-20266) .NET: Thin 3.0: TestDataStreamerMetrics is flaky

[Pavel Tupitsyn (Jira)]

 [ 
https://issues.apache.org/jira/browse/IGNITE-20266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pavel Tupitsyn updated IGNITE-20266:

Ignite Flags:   (was: Docs Required,Release Notes Required)

> .NET: Thin 3.0: TestDataStreamerMetrics is flaky
> 
>
> Key: IGNITE-20266
> URL: https://issues.apache.org/jira/browse/IGNITE-20266
> Project: Ignite
>  Issue Type: Bug
>  Components: platforms, thin client
>Affects Versions: 3.0.0-beta1
>Reporter: Pavel Tupitsyn
>Assignee: Pavel Tupitsyn
>Priority: Major
>  Labels: ignite-3
> Fix For: 3.0.0-beta2
>
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> https://ci.ignite.apache.org/test/5503643215833216881?currentProjectId=ApacheIgnite3xGradle_Test=true=
> {code}
> streamer-batches-active
>   Expected: 1
>   But was:  2
>at 
> Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
>  in 
> /opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
>  248
>at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
> /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
>  68
>at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
> /_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
>at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
> /_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 75
>at 
> Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1
>  data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 
> schemaProvider, Func`1 partitionAssignmentProvider, DataStreamerOptions 
> options, CancellationToken cancellationToken) in 
> /opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs:line
>  92
>at 
> Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1
>  data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 
> schemaProvider, Func`1 partitionAssignmentProvider, DataStreamerOptions 
> options, CancellationToken cancellationToken) in 
> /opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs:line
>  92
>at 
> Apache.Ignite.Internal.Table.RecordView`1.StreamDataAsync(IAsyncEnumerable`1 
> data, DataStreamerOptions options, CancellationToken cancellationToken) in 
> /opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/RecordView.cs:line
>  300
>at Apache.Ignite.Tests.MetricsTests.TestDataStreamerMetrics() in 
> /opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
>  224
>at 
> NUnit.Framework.Internal.TaskAwaitAdapter.GenericAdapter`1.BlockUntilCompleted()
>at 
> NUnit.Framework.Internal.MessagePumpStrategy.NoMessagePumpStrategy.WaitForCompletion(AwaitAdapter
>  awaiter)
>at NUnit.Framework.Internal.AsyncToSyncAdapter.Await(Func`1 invoke)
>at 
> NUnit.Framework.Internal.Commands.TestMethodCommand.RunTestMethod(TestExecutionContext
>  context)
>at 
> NUnit.Framework.Internal.Commands.TestMethodCommand.Execute(TestExecutionContext
>  context)
>at 
> NUnit.Framework.Internal.Commands.BeforeAndAfterTestCommand.<>c__DisplayClass1_0.b__0()
>at 
> NUnit.Framework.Internal.Commands.DelegatingTestCommand.RunTestMethodInThreadAbortSafeZone(TestExecutionContext
>  context, Action action)
> 1)at 
> Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
>  in 
> /opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
>  248
>at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
> /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
>  68
>at 
> System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine&
>  stateMachine)
>at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore()
>at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
> /_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
>at 
> System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine&
>  stateMachine)
>at System.Linq.AsyncIteratorBase`1.MoveNextAsync()
>at 
> System.Runtime.CompilerServices.ConfiguredCancelableAsyncEnumerable`1.Enumerator.MoveNextAsync()
>at 
> Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1
>  data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 
> schemaProvider, Func`1 partitionAssignmentProvider, DataStreamerOptions 
> options, CancellationToken cancellationToken)
>at 
> 

[jira] [Updated] (IGNITE-20266) .NET: Thin 3.0: TestDataStreamerMetrics is flaky

[Pavel Tupitsyn (Jira)]

 [ 
https://issues.apache.org/jira/browse/IGNITE-20266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pavel Tupitsyn updated IGNITE-20266:

Description: 
https://ci.ignite.apache.org/test/5503643215833216881?currentProjectId=ApacheIgnite3xGradle_Test=true=

{code}
streamer-batches-active
  Expected: 1
  But was:  2
   at 
Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
 in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 248
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
 68
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 75
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs:line
 92
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs:line
 92
   at 
Apache.Ignite.Internal.Table.RecordView`1.StreamDataAsync(IAsyncEnumerable`1 
data, DataStreamerOptions options, CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/RecordView.cs:line
 300
   at Apache.Ignite.Tests.MetricsTests.TestDataStreamerMetrics() in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 224
   at 
NUnit.Framework.Internal.TaskAwaitAdapter.GenericAdapter`1.BlockUntilCompleted()
   at 
NUnit.Framework.Internal.MessagePumpStrategy.NoMessagePumpStrategy.WaitForCompletion(AwaitAdapter
 awaiter)
   at NUnit.Framework.Internal.AsyncToSyncAdapter.Await(Func`1 invoke)
   at 
NUnit.Framework.Internal.Commands.TestMethodCommand.RunTestMethod(TestExecutionContext
 context)
   at 
NUnit.Framework.Internal.Commands.TestMethodCommand.Execute(TestExecutionContext
 context)
   at 
NUnit.Framework.Internal.Commands.BeforeAndAfterTestCommand.<>c__DisplayClass1_0.b__0()
   at 
NUnit.Framework.Internal.Commands.DelegatingTestCommand.RunTestMethodInThreadAbortSafeZone(TestExecutionContext
 context, Action action)
1)at 
Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
 in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 248
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
 68
   at 
System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine&
 stateMachine)
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore()
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
   at 
System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine&
 stateMachine)
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync()
   at 
System.Runtime.CompilerServices.ConfiguredCancelableAsyncEnumerable`1.Enumerator.MoveNextAsync()
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken)
   at 
System.Runtime.CompilerServices.AsyncTaskMethodBuilder`1.AsyncStateMachineBox`1.ExecutionContextCallback(Object
 s)
{code}

  was:
https://ci.ignite.apache.org/test/5503643215833216881?currentProjectId=ApacheIgnite3xGradle_Test=true=%3Cdefault%3E

{code}
streamer-batches-active
  Expected: 1
  But was:  2
   at 
Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
 in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 248
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
 68
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
   at 

[jira] [Updated] (IGNITE-20266) .NET: Thin 3.0: TestDataStreamerMetrics is flaky

[Pavel Tupitsyn (Jira)]

 [ 
https://issues.apache.org/jira/browse/IGNITE-20266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pavel Tupitsyn updated IGNITE-20266:

Description: 
https://ci.ignite.apache.org/test/5503643215833216881?currentProjectId=ApacheIgnite3xGradle_Test=true=%3Cdefault%3E

{code}
streamer-batches-active
  Expected: 1
  But was:  2
   at 
Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
 in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 248
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
 68
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 75
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs:line
 92
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs:line
 92
   at 
Apache.Ignite.Internal.Table.RecordView`1.StreamDataAsync(IAsyncEnumerable`1 
data, DataStreamerOptions options, CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/RecordView.cs:line
 300
   at Apache.Ignite.Tests.MetricsTests.TestDataStreamerMetrics() in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 224
   at 
NUnit.Framework.Internal.TaskAwaitAdapter.GenericAdapter`1.BlockUntilCompleted()
   at 
NUnit.Framework.Internal.MessagePumpStrategy.NoMessagePumpStrategy.WaitForCompletion(AwaitAdapter
 awaiter)
   at NUnit.Framework.Internal.AsyncToSyncAdapter.Await(Func`1 invoke)
   at 
NUnit.Framework.Internal.Commands.TestMethodCommand.RunTestMethod(TestExecutionContext
 context)
   at 
NUnit.Framework.Internal.Commands.TestMethodCommand.Execute(TestExecutionContext
 context)
   at 
NUnit.Framework.Internal.Commands.BeforeAndAfterTestCommand.<>c__DisplayClass1_0.b__0()
   at 
NUnit.Framework.Internal.Commands.DelegatingTestCommand.RunTestMethodInThreadAbortSafeZone(TestExecutionContext
 context, Action action)
1)at 
Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
 in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 248
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
 68
   at 
System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine&
 stateMachine)
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore()
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
   at 
System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine&
 stateMachine)
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync()
   at 
System.Runtime.CompilerServices.ConfiguredCancelableAsyncEnumerable`1.Enumerator.MoveNextAsync()
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken)
   at 
System.Runtime.CompilerServices.AsyncTaskMethodBuilder`1.AsyncStateMachineBox`1.ExecutionContextCallback(Object
 s)
{code}

  was:
{code}
streamer-batches-active
  Expected: 1
  But was:  2
   at 
Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
 in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 248
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
 68
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 75
   at 

[jira] [Updated] (IGNITE-20266) .NET: Thin 3.0: TestDataStreamerMetrics is flaky

[Pavel Tupitsyn (Jira)]

 [ 
https://issues.apache.org/jira/browse/IGNITE-20266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Pavel Tupitsyn updated IGNITE-20266:

Description: 
{code}
streamer-batches-active
  Expected: 1
  But was:  2
   at 
Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
 in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 248
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
 68
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 75
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs:line
 92
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/DataStreamer.cs:line
 92
   at 
Apache.Ignite.Internal.Table.RecordView`1.StreamDataAsync(IAsyncEnumerable`1 
data, DataStreamerOptions options, CancellationToken cancellationToken) in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite/Internal/Table/RecordView.cs:line
 300
   at Apache.Ignite.Tests.MetricsTests.TestDataStreamerMetrics() in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 224
   at 
NUnit.Framework.Internal.TaskAwaitAdapter.GenericAdapter`1.BlockUntilCompleted()
   at 
NUnit.Framework.Internal.MessagePumpStrategy.NoMessagePumpStrategy.WaitForCompletion(AwaitAdapter
 awaiter)
   at NUnit.Framework.Internal.AsyncToSyncAdapter.Await(Func`1 invoke)
   at 
NUnit.Framework.Internal.Commands.TestMethodCommand.RunTestMethod(TestExecutionContext
 context)
   at 
NUnit.Framework.Internal.Commands.TestMethodCommand.Execute(TestExecutionContext
 context)
   at 
NUnit.Framework.Internal.Commands.BeforeAndAfterTestCommand.<>c__DisplayClass1_0.b__0()
   at 
NUnit.Framework.Internal.Commands.DelegatingTestCommand.RunTestMethodInThreadAbortSafeZone(TestExecutionContext
 context, Action action)
1)at 
Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
 in 
/opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
 248
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToAsyncEnumerable.cs:line
 68
   at 
System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine&
 stateMachine)
   at System.Linq.AsyncEnumerable.AsyncEnumerableAdapter`1.MoveNextCore()
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync() in 
/_/Ix.NET/Source/System.Linq.Async/System/Linq/AsyncIterator.cs:line 70
   at 
System.Runtime.CompilerServices.AsyncMethodBuilderCore.Start[TStateMachine](TStateMachine&
 stateMachine)
   at System.Linq.AsyncIteratorBase`1.MoveNextAsync()
   at 
System.Runtime.CompilerServices.ConfiguredCancelableAsyncEnumerable`1.Enumerator.MoveNextAsync()
   at 
Apache.Ignite.Internal.Table.DataStreamer.StreamDataAsync[T](IAsyncEnumerable`1 
data, Func`4 sender, IRecordSerializerHandler`1 writer, Func`1 schemaProvider, 
Func`1 partitionAssignmentProvider, DataStreamerOptions options, 
CancellationToken cancellationToken)
   at 
System.Runtime.CompilerServices.AsyncTaskMethodBuilder`1.AsyncStateMachineBox`1.ExecutionContextCallback(Object
 s)
{code}

> .NET: Thin 3.0: TestDataStreamerMetrics is flaky
> 
>
> Key: IGNITE-20266
> URL: https://issues.apache.org/jira/browse/IGNITE-20266
> Project: Ignite
>  Issue Type: Bug
>  Components: platforms, thin client
>Affects Versions: 3.0.0-beta1
>Reporter: Pavel Tupitsyn
>Assignee: Pavel Tupitsyn
>Priority: Major
>  Labels: ignite-3
> Fix For: 3.0.0-beta2
>
>
> {code}
> streamer-batches-active
>   Expected: 1
>   But was:  2
>at 
> Apache.Ignite.Tests.MetricsTests.g__GetTuples|13_0()+MoveNext()
>  in 
> /opt/buildagent/work/b8d4df1365f1f1e5/modules/platforms/dotnet/Apache.Ignite.Tests/MetricsTests.cs:line
>  248
>at