|
Change Parameter Type savepointPath : String to savepointSettings : SavepointRestoreSettings in method public run(compiledPlan FlinkPlan, libraries List<URL>, classpaths List<URL>, classLoader ClassLoader, savepointSettings SavepointRestoreSettings) : JobSubmissionResult in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Change Parameter Type savepointPath : String to savepointSettings : SavepointRestoreSettings in method public ContextEnvironmentFactory(client ClusterClient, jarFilesToAttach List<URL>, classpathsToAttach List<URL>, userCodeClassLoader ClassLoader, defaultParallelism int, isDetached boolean, savepointSettings SavepointRestoreSettings) in class org.apache.flink.client.program.ContextEnvironmentFactory |
From |
To |
|
Change Parameter Type savepointPath : String to savepointSettings : SavepointRestoreSettings in method private getJobGraph(optPlan FlinkPlan, jarFiles List<URL>, classpaths List<URL>, savepointSettings SavepointRestoreSettings) : JobGraph in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Change Parameter Type savepointPath : String to savepointSettings : SavepointRestoreSettings in method public getJobGraph(prog PackagedProgram, optPlan FlinkPlan, savepointSettings SavepointRestoreSettings) : JobGraph in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Change Parameter Type savepointPath : String to savepointSettings : SavepointRestoreSettings in method public ContextEnvironment(remoteConnection ClusterClient, jarFiles List<URL>, classpaths List<URL>, userCodeClassLoader ClassLoader, savepointSettings SavepointRestoreSettings) in class org.apache.flink.client.program.ContextEnvironment |
From |
To |
|
Change Parameter Type savepointPath : String to savepointSettings : SavepointRestoreSettings in method public run(jobWithJars JobWithJars, parallelism int, savepointSettings SavepointRestoreSettings) : JobSubmissionResult in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Change Parameter Type savepointPath : String to savepointSettings : SavepointRestoreSettings in method public DetachedEnvironment(remoteConnection ClusterClient, jarFiles List<URL>, classpaths List<URL>, userCodeClassLoader ClassLoader, savepointSettings SavepointRestoreSettings) in class org.apache.flink.client.program.DetachedEnvironment |
From |
To |
|
Rename Parameter savepointPath : String to savepointSettings : SavepointRestoreSettings in method public getJobGraph(prog PackagedProgram, optPlan FlinkPlan, savepointSettings SavepointRestoreSettings) : JobGraph in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Rename Parameter savepointPath : String to savepointSettings : SavepointRestoreSettings in method public ContextEnvironment(remoteConnection ClusterClient, jarFiles List<URL>, classpaths List<URL>, userCodeClassLoader ClassLoader, savepointSettings SavepointRestoreSettings) in class org.apache.flink.client.program.ContextEnvironment |
From |
To |
|
Rename Parameter savepointPath : String to savepointSettings : SavepointRestoreSettings in method public run(jobWithJars JobWithJars, parallelism int, savepointSettings SavepointRestoreSettings) : JobSubmissionResult in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Rename Parameter savepointPath : String to savepointSettings : SavepointRestoreSettings in method public DetachedEnvironment(remoteConnection ClusterClient, jarFiles List<URL>, classpaths List<URL>, userCodeClassLoader ClassLoader, savepointSettings SavepointRestoreSettings) in class org.apache.flink.client.program.DetachedEnvironment |
From |
To |
|
Rename Parameter savepointPath : String to savepointSettings : SavepointRestoreSettings in method public run(compiledPlan FlinkPlan, libraries List<URL>, classpaths List<URL>, classLoader ClassLoader, savepointSettings SavepointRestoreSettings) : JobSubmissionResult in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Rename Parameter savepointPath : String to savepointSettings : SavepointRestoreSettings in method public ContextEnvironmentFactory(client ClusterClient, jarFilesToAttach List<URL>, classpathsToAttach List<URL>, userCodeClassLoader ClassLoader, defaultParallelism int, isDetached boolean, savepointSettings SavepointRestoreSettings) in class org.apache.flink.client.program.ContextEnvironmentFactory |
From |
To |
|
Rename Parameter savepointPath : String to savepointSettings : SavepointRestoreSettings in method private getJobGraph(optPlan FlinkPlan, jarFiles List<URL>, classpaths List<URL>, savepointSettings SavepointRestoreSettings) : JobGraph in class org.apache.flink.client.program.ClusterClient |
From |
To |