Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-4346 Implement basic RPC abstraction
  3. FLINK-7754

Complete termination future after actor has been stopped.

    XMLWordPrintableJSON

Details

    Description

      At the moment, we complete the termination future when the postStop method of the RpcActor has been executed. This, however, does not mean that the underlying actor has been stopped. We should rather complete the future in the AkkaRpcService#stopServer method where we close the actor with a graceful shutdown.

      Attachments

        Issue Links

          Activity

            People

              trohrmann Till Rohrmann
              trohrmann Till Rohrmann
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: