[
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.<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}
> .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.<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)
