Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-16654 Implement Application Mode according to FLIP-85
  3. FLINK-16655

Introduce the EmbeddedExecutor for executing the main() on the Dispatcher

Agile BoardRank to TopRank to BottomAttach filesAttach ScreenshotBulk Copy AttachmentsBulk Move AttachmentsVotersWatch issueWatchersConvert to IssueLinkCloneLabelsUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      Running the user's main method in "Application Mode" implies:
      1) launching a dedicated cluster for the application's jobs
      2) running the user's main on the cluster, alongside the Dispatcher

      The EmbeddedExecutor will conceptually be like the existing Executors for session clusters, with the difference that this time there is no need to go through REST as this will be running already on the same machine as the Dispatcher.

      This executor, apart from the application mode can also be used in the case of the web submission and the StandaloneJobClusterEntryPoint which so far do not use executors.

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            kkl0u Kostas Kloudas
            kkl0u Kostas Kloudas
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

              Estimated:
              Original Estimate - Not Specified
              Not Specified
              Remaining:
              Remaining Estimate - 0h
              0h
              Logged:
              Time Spent - 20m
              20m

              Slack

                Issue deployment