FabricException: The primary or stateless instance for the partition

Question

I am following a tutorial from [this book]:

I am getting the following exception:

There's no doubt that my nodes are running fine:

Here's how my stateless service is setup:

internal sealed class MyStatelessService : StatelessService
    {
        public MyStatelessService(StatelessServiceContext context)
            : base(context)
        { }

        /// <summary>
        /// Optional override to create listeners (e.g., TCP, HTTP) for this service replica to handle client or user requests.
        /// </summary>
        /// <returns>A collection of listeners.</returns>
        protected override IEnumerable<ServiceInstanceListener> CreateServiceInstanceListeners()
        {
            return new ServiceInstanceListener[0];
        }


        /// <summary>
        /// This is the main entry point for your service instance.
        /// </summary>
        /// <param name="cancellationToken">Canceled when Service Fabric needs to shut down this service instance.</param>
        protected override async Task RunAsync(CancellationToken cancellationToken)
        {
            // TODO: Replace the following sample code with your own logic 
            //       or remove this RunAsync override if it's not needed in your service.

            long iterations = 0;

            while (true)
            {
                cancellationToken.ThrowIfCancellationRequested();

                ServiceEventSource.Current.ServiceMessage(this.Context, "Working-{0}", ++iterations);

                await Task.Delay(TimeSpan.FromSeconds(1), cancellationToken);
            }
        }
    }

The way I deploy and get this exception:

What am I doing wrong? How can I get my client connected to my cluster?

The entire solution can be viewed here.

Answer 1

Two things:

1. Your ICalculatorService have to be defined in another library project, in order to be shared between your stateless service library and your client project. So:

   • Create a new library project MyStatelessService.Interfaces
   • Add to it NuGet package: Microsoft.ServiceFabric.Services.Remoting
   • Define in this library your ICalculatorService
   • Remove ICalculatorService from your other two projects
   • Add a reference to MyStatelessService.Interfaces to your client application and your stateless service library.
   • Fix references to ICalculatorService
   • All your ICalculatorService should be referenced from the same library

Your client will be:

using Microsoft.ServiceFabric.Services.Remoting.Client;
using MyStatelessService.Interfaces;
using System;

static void Main(string[] args)
{
    var calculatorClient = ServiceProxy.Create<ICalculatorService>
        (new Uri("fabric:/CalculatorService/MyStatelessService"));

    var result = calculatorClient.Add(1, 2).Result;

    Console.WriteLine(result);
    Console.ReadKey();
}

2. Change your MyStatelessService's Program.cs part after the try statement with this:

   ServiceRuntime.RegisterServiceAsync("MyStatelessServiceType",
       context => new CalculatorService(context)).GetAwaiter().GetResult();
   
   ServiceEventSource.Current.ServiceTypeRegistered(Process.GetCurrentProcess().Id, typeof(CalculatorService).Name);
   

Instead of CalculatorService, you were referencing MyStatelessService.