Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

WIP: Ddata serialization opts #7014

Draft
wants to merge 5 commits into
base: dev
Choose a base branch
from

Fixups

fbd3f07
Select commit
Loading
Failed to load commit list.
Draft

WIP: Ddata serialization opts #7014

Fixups
fbd3f07
Select commit
Loading
Failed to load commit list.
Azure Pipelines / PR Validation failed Dec 3, 2023 in 56m 18s

Build #2023.12.3.2 had test failures

Details

Tests

  • Failed: 4 (0.15%)
  • Passed: 2,638 (96.03%)
  • Other: 105 (3.82%)
  • Total: 2,747

Annotations

Check failure on line 11227 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L11227

Bash exited with code '42'.

Check failure on line 3845 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L3845

Process completed with exit code 42.

Check failure on line 16 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L16

Bash wrote one or more lines to the standard error stream.

Check failure on line 1 in Akka.DistributedData.Tests.Serialization.ReplicatedDataSerializerSpec.ReplicatedDataSerializer_should_serialize_GSet

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.DistributedData.Tests.Serialization.ReplicatedDataSerializerSpec.ReplicatedDataSerializer_should_serialize_GSet

System.NullReferenceException : Object reference not set to an instance of an object.
Raw output
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.SerDeserGenericCache.MakeInstanceCallOneGenericOneArg[TArg,TRet](MethodInfo nonConstructedGenericMethodInfo, Type tk, Boolean convert) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.GenericCache.cs:line 631
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.SerDeserGenericCache.<>c.<ToGenericGSet>b__10_0(Type kc) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.GenericCache.cs:line 201
   at System.Collections.Concurrent.ConcurrentDictionary`2.GetOrAdd(TKey key, Func`2 valueFactory)
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.SerDeserGenericCache.ToGenericGSet(Type k, ReplicatedDataSerializer serializer, RepeatedField`1 operation) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.GenericCache.cs:line 199
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.GSetFromBinary(Byte[] bytes) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.cs:line 752
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.FromBinary(Byte[] bytes, String manifest) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.cs:line 123
   at Akka.Serialization.Serialization.Deserialize(Byte[] bytes, Int32 serializerId, String manifest) in D:\a\1\s\src\core\Akka\Serialization\Serialization.cs:line 464
   at Akka.DistributedData.Tests.Serialization.ReplicatedDataSerializerSpec.CheckSerialization[T](T expected) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData.Tests\Serialization\ReplicatedDataSerializerSpec.cs:line 278
   at Akka.DistributedData.Tests.Serialization.ReplicatedDataSerializerSpec.ReplicatedDataSerializer_should_serialize_GSet() in D:\a\1\s\src\contrib\cluster\Akka.DistributedData.Tests\Serialization\ReplicatedDataSerializerSpec.cs:line 47
   at System.RuntimeMethodHandle.InvokeMethod(Object target, Void** arguments, Signature sig, Boolean isConstructor)
   at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)

Check failure on line 1 in Akka.Streams.Tests.Dsl.TickSourceSpec.A_Flow_based_on_a_tick_publisher_must_be_possible_to_cancel

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.TickSourceSpec.A_Flow_based_on_a_tick_publisher_must_be_possible_to_cancel

Failed: Expected no messages during 00:00:00.2000000, instead we received <TestSubscriber.OnNext(tick)> from [akka://TickSourceSpec-212/user/StreamSupervisor-242/Flow-0-0-tickSource#1457277796] after 00:00:00.9999769
Raw output
   at Akka.TestKit.Xunit2.XunitAssertions.Fail(String format, Object[] args) in /home/vsts/work/1/s/src/contrib/testkits/Akka.TestKit.Xunit2/XunitAssertions.cs:line 26
   at Akka.TestKit.TestKitBase.InternalExpectNoMsgAsync(TimeSpan duration, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 524
   at Akka.TestKit.TestKitBase.ExpectNoMsgAsync(TimeSpan duration, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 490
   at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNoMsgAsync(TimeSpan remaining, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber.cs:line 237
   at Akka.Streams.Tests.Dsl.TickSourceSpec.<A_Flow_based_on_a_tick_publisher_must_be_possible_to_cancel>b__8_0() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/TickSourceSpec.cs:line 147
   at Akka.Streams.TestKit.Utils.<>c__DisplayClass5_0.<<AssertAllStagesStoppedAsync>b__0>d.MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 59
--- End of stack trace from previous location ---
   at Akka.TestKit.Extensions.TaskExtensions.<>c__DisplayClass5_0`1.<<ShouldCompleteWithin>b__0>d.MoveNext()
--- End of stack trace from previous location ---
   at FluentAssertions.Specialized.GenericAsyncFunctionAssertions`1.CompleteWithinAsync(TimeSpan timeSpan, String because, Object[] becauseArgs)
   at Akka.TestKit.Extensions.TaskExtensions.ShouldCompleteWithin[T](Task`1 task, TimeSpan timeout, String because, Object[] becauseArgs)
   at Akka.Streams.TestKit.Utils.AssertAllStagesStoppedAsync[T](TestKitBase spec, Func`1 block, IMaterializer materializer, Nullable`1 timeout, CancellationToken cancellationToken)
   at Akka.Streams.TestKit.Utils.AssertAllStagesStoppedAsync(TestKitBase spec, Func`1 block, IMaterializer materializer, Nullable`1 timeout, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 57
   at Akka.Streams.Tests.Dsl.TickSourceSpec.A_Flow_based_on_a_tick_publisher_must_be_possible_to_cancel() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/TickSourceSpec.cs:line 137
--- End of stack trace from previous location ---

Check failure on line 1 in Akka.DistributedData.Tests.Serialization.ReplicatedDataSerializerSpec.ReplicatedDataSerializer_should_serialize_GSet

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.DistributedData.Tests.Serialization.ReplicatedDataSerializerSpec.ReplicatedDataSerializer_should_serialize_GSet

System.NullReferenceException : Object reference not set to an instance of an object.
Raw output
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.SerDeserGenericCache.MakeInstanceCallOneGenericOneArg[TArg,TRet](MethodInfo nonConstructedGenericMethodInfo, Type tk, Boolean convert) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.GenericCache.cs:line 631
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.SerDeserGenericCache.<>c.<ToGenericGSet>b__10_0(Type kc) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.GenericCache.cs:line 201
   at System.Collections.Concurrent.ConcurrentDictionary`2.GetOrAdd(TKey key, Func`2 valueFactory)
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.SerDeserGenericCache.ToGenericGSet(Type k, ReplicatedDataSerializer serializer, RepeatedField`1 operation) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.GenericCache.cs:line 199
   at Akka.DistributedData.Serialization.ReplicatedDataSerializer.FromBinary(Byte[] bytes, String manifest) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData\Serialization\ReplicatedDataSerializer.cs:line 123
   at Akka.Serialization.Serialization.Deserialize(Byte[] bytes, Int32 serializerId, String manifest) in D:\a\1\s\src\core\Akka\Serialization\Serialization.cs:line 464
   at Akka.DistributedData.Tests.Serialization.ReplicatedDataSerializerSpec.CheckSerialization[T](T expected) in D:\a\1\s\src\contrib\cluster\Akka.DistributedData.Tests\Serialization\ReplicatedDataSerializerSpec.cs:line 278
   at Akka.DistributedData.Tests.Serialization.ReplicatedDataSerializerSpec.ReplicatedDataSerializer_should_serialize_GSet() in D:\a\1\s\src\contrib\cluster\Akka.DistributedData.Tests\Serialization\ReplicatedDataSerializerSpec.cs:line 47

Check failure on line 1 in Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_work_when_first_element_is_split_by

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_work_when_first_element_is_split_by

Expected task to complete within 3s.
Raw output
   at FluentAssertions.Execution.XUnit2TestFramework.Throw(String message)
   at FluentAssertions.Execution.TestFrameworkProvider.Throw(String message)
   at FluentAssertions.Execution.DefaultAssertionStrategy.HandleFailure(String message)
   at FluentAssertions.Execution.AssertionScope.FailWith(Func`1 failReasonFunc)
   at FluentAssertions.Specialized.NonGenericAsyncFunctionAssertions.CompleteWithinAsync(TimeSpan timeSpan, String because, Object[] becauseArgs)
   at Akka.TestKit.Extensions.TaskExtensions.ShouldCompleteWithin(Task task, TimeSpan timeout, String because, Object[] becauseArgs) in /home/vsts/work/1/s/src/core/Akka.TestKit/Extensions/TaskExtensions.cs:line 158
   at Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_work_when_first_element_is_split_by() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/FlowSplitWhenSpec.cs:line 145
--- End of stack trace from previous location ---