|
|
|
FLINK-15121
|
FLINK-14376
Add public constructors for execution environments that takes Configuration
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-15120
|
FLINK-14376
Make FlinkYarnCli#isActive() & #getApplicationId() respect config APPLICATION_ID
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-15119
|
FLINK-14376
Remove PlanExecutor and its subclasses
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-15118
|
FLINK-14376
Make flink-scala-shell use Executors
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-15033
|
FLINK-14376
Remove unused RemoteEnvirnment.executeRemotely() (FLINK-11048)
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14972
|
FLINK-14376
Implement RemoteExecutor as a new Executor
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14947
|
FLINK-14376
Implement LocalExecutor as new Executor interface
|
Kostas Kloudas
|
Zili Chen
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14916
|
FLINK-14376
Asynchronously deploy cluster in AbstractJobClusterExecutor#execute
|
Kostas Kloudas
|
Zili Chen
|
|
Closed |
Won't Fix
|
|
|
|
|
|
|
|
FLINK-14851
|
FLINK-14376
Make the (Stream)ContextEnvironment use the Executors
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14850
|
FLINK-14376
Refactor Executor interface and introduce a minimal JobClient interface
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14840
|
FLINK-14376
Use new Executor interface in SQL cli
|
Aljoscha Krettek
|
Aljoscha Krettek
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14758
|
FLINK-14376
Add Executor-related interfaces and utilities
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14745
|
FLINK-14376
Put job jars from PackagedProgram to Configuration
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14629
|
FLINK-14376
Refactor ScalaShellRemote(Stream)Environment to simplify inheritance
|
Zili Chen
|
Zili Chen
|
|
Closed |
Won't Do
|
|
|
|
|
|
|
|
FLINK-14502
|
FLINK-14376
Make ClusterDescriptor/ClusterSpecification creation configuration-based.
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14501
|
FLINK-14376
Move ClusterDescriptor/ClusterSpecification creation from the CustomCommandLine to a ClusterClientFactory
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-14377
|
FLINK-14376
Translate ProgramOptions relevant for job execution to ConfigOptions.
|
Kostas Kloudas
|
Kostas Kloudas
|
|
Closed |
Fixed
|
|
|
|
|