[ https://issues.apache.org/jira/browse/IGNITE-20266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760354#comment-17760354 ]
Igor Sapego commented on IGNITE-20266: -------------------------------------- Looks good to me. > .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&expandTestHistoryChartSection=true&branch= > {code} > streamer-batches-active > Expected: 1 > But was: 2 > at > Apache.Ignite.Tests.MetricsTests.<TestDataStreamerMetrics>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.<Execute>b__0() > at > NUnit.Framework.Internal.Commands.DelegatingTestCommand.RunTestMethodInThreadAbortSafeZone(TestExecutionContext > context, Action action) > 1) at > Apache.Ignite.Tests.MetricsTests.<TestDataStreamerMetrics>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} -- This message was sent by Atlassian Jira (v8.20.10#820010)