When I first register an event via Stream on the client side. This error occurs.
I have consulted the relevant documentation. I have checked the documentation and searched git and Google for the relevant information with no luck. Where do I go to solve this problem?
I have consulted the relevant documentation. I have checked the documentation and searched git and Google for the relevant information with no luck. Where do I go to solve this problem?
System.NullReferenceException: Object reference not set to an instance of an object.
at Orleans.Internal.OrleansTaskExtentions.<ToTypedTask>g__ConvertAsync|4_0T
at Orleans.Streams.StreamPubSubImpl.GetAllSubscriptions(StreamId streamId, IStreamConsumerExtension streamConsumer)
at Orleans.Streams.StreamConsumer`1.GetAllSubscriptions()
at Orleans.Internal.OrleansTaskExtentions.<ToTypedTask>g__ConvertAsync|4_0T
at Orleans.Streams.StreamPubSubImpl.GetAllSubscriptions(StreamId streamId, IStreamConsumerExtension streamConsumer)
at Orleans.Streams.StreamConsumer`1.GetAllSubscriptions()
My Client Code
Client = new ClientBuilder()
.UseCosmosDBGatewayListProvider(options =>
{
options.AccountEndpoint = "---";
options.AccountKey = "---";
})
.Configure<ClusterOptions>(options =>
{
options.ClusterId = "Test1";
options.ServiceId = "HelloWorld";
})
.Configure<GatewayOptions>(d => d.GatewayListRefreshPeriod = TimeSpan.FromSeconds(5))
.ConfigureLogging(logging => logging.AddConsole())
.AddSimpleMessageStreamProvider(Constants.GuildInfoStreamProvider)
.Build();
Register Code
var guildProvider = actorComponent.Client.GetStreamProvider(Constants.GuildInfoStreamProvider);
var guildChanged = guildProvider.GetStream<PlayerGuildChangedMsg>(Guid.Empty, info.id);
var guildChangedSubEvent = await guildChanged.SubscribeAsync((msg, token) => GuildChangedCallback(session, msg,db));
Silo Code
ISiloHostBuilder builder = new SiloHostBuilder()
.AddCosmosDBGrainStorage("Profile",options =>
{
options.Client = DatabaseClient.Core;
options.CanCreateResources = true;
})
.AddCosmosDBGrainStorage("PubSubStore",options =>
{
options.Client = DatabaseClient.Core;
})
.UseCosmosDBMembership(options =>
{
options.Client = DatabaseClient.Core;
options.CanCreateResources = true;
})
.Configure<ClusterOptions>(options =>
{
options.ClusterId = "Test1";
options.ServiceId = "HelloWorld";
})
.Configure<EndpointOptions>(options =>
{
options.AdvertisedIPAddress = IPAddress.Loopback;
options.SiloPort = siloPort;
options.GatewayPort = gatewayPort;
})
.ConfigureServices(collection =>
{
collection.AddSingleton(DatabaseClient);
})
.AddSimpleMessageStreamProvider(Constants.GuildInfoStreamProvider)
.ConfigureApplicationParts(parts => parts.AddApplicationPart(typeof(StateCode).Assembly).WithReferences())
.ConfigureLogging(logging => logging.AddConsole());
The error occurs when I use GetAllSubscriptionHandles. But calling SubscribeAsync also throws an error that there is no instance
public class PlayerGuildChangedMsg
{
public long GuildId;
}
Has anyone given any thought to reducing the overhead of looking for non-existent persisted grains? Our application does a series of jobs. Each job has a unique GUID and grains within the job are keyed on that GUID (and other things). So we know at the start of the job, none of the grains for this job are on persistent store. However looking on the persistent store on activation of every grain is a significant overhead. Has anyone got a way of reducing or removing this overhead? Some combination of Bloom filters and the grain catalog?
But you could try it with a custom storage provider
By some default way, i.e.
if(SkipStorage) { return; }.
@zeus82 For me no need, but if you want to examine this case and maybe share, go ahead. I will read in any case and if you need something, I pick from here.
I'll be digging into it more this weekend
@zeus82 :+1:
It's arguable, @veikkoeeva & @OracPrime. I believe it may be a good-to-have feature, however my main concern is that it would complicate semantics & lead users into difficult to troubleshoot scenarios where they are accidentally always setting it due to logic bugs in their applications
first installation = first activation
@govenkat-ms it really just depends on how you want to set up your networking. You have control over whether you listen on a specific interface (IP address) or all interfaces. So it's nothing Orleans-specific. In general, you can set it to
true in k8s and you shouldn't have any negative implications because of that (you are already on a container IP, for example, and not a host interface)
Yes, @OracPrime, much appreciated. I for one appreciate any hints on real issues. If nothing else, it takes time to just write something semi-coherent about findings. But maybe that's the way: recognize it, solidify the foundations and build on top. We should document somehow these more in Orleans community. :)
@ReubenBond Got it. Thanks. One more thing. We recently switched to using a PreferLocalPlacement strategy and noticed the following exception: System.ArgumentNullException: Value cannot be null. (Parameter 'existingActivationAddress')
at Orleans.Runtime.Catalog.RegisterActivationInGrainDirectoryAndValidate(ActivationData activation)
at Orleans.Runtime.Catalog.InitActivation(ActivationData activation, Dictionary
at Orleans.Runtime.Catalog.RegisterActivationInGrainDirectoryAndValidate(ActivationData activation)
at Orleans.Runtime.Catalog.InitActivation(ActivationData activation, Dictionary
2 requestContextData)
at Orleans.Runtime.Catalog.InitActivation(ActivationData activation, Dictionary2 requestContextData)
Forwarding 1 requests destined for address S10.241.32.192:11114:348371692*grn/2E596F41/1ca50c90@854be08e to address (null) after Failed RegisterActivationInGrainDirectory
cc @benjaminpetit