[ https://issues.apache.org/jira/browse/FLINK-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kostas Kloudas updated FLINK-16655: ----------------------------------- Fix Version/s: 1.11.0 > Introduce the EmbeddedExecutor for executing the main() on the Dispatcher > ------------------------------------------------------------------------- > > Key: FLINK-16655 > URL: https://issues.apache.org/jira/browse/FLINK-16655 > Project: Flink > Issue Type: Sub-task > Components: Client / Job Submission > Affects Versions: 1.10.0 > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > Priority: Major > Labels: pull-request-available > Fix For: 1.11.0 > > Time Spent: 20m > Remaining Estimate: 0h > > 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. -- This message was sent by Atlassian Jira (v8.3.4#803005)