|
Change Parameter Type client : Client to client : ClusterClient in method protected executeProgram(program PackagedProgram, client ClusterClient, parallelism int) : int in class org.apache.flink.client.CliFrontendRunTest.RunTestingCliFrontend |
From |
To |
|
Change Parameter Type client : Client to client : ClusterClient in method public ContextEnvironmentFactory(client ClusterClient, jarFilesToAttach List<URL>, classpathsToAttach List<URL>, userCodeClassLoader ClassLoader, defaultParallelism int, isDetached boolean, savepointPath String) in class org.apache.flink.client.program.ContextEnvironmentFactory |
From |
To |
|
Change Parameter Type client : Client to client : ClusterClient in method protected executeProgram(program PackagedProgram, client ClusterClient, parallelism int) : int in class org.apache.flink.client.CliFrontend |
From |
To |
|
Change Parameter Type remoteConnection : Client to remoteConnection : ClusterClient in method public ContextEnvironment(remoteConnection ClusterClient, jarFiles List<URL>, classpaths List<URL>, userCodeClassLoader ClassLoader, savepointPath String) in class org.apache.flink.client.program.ContextEnvironment |
From |
To |
|
Change Parameter Type remoteConnection : Client to remoteConnection : ClusterClient in method public DetachedEnvironment(remoteConnection ClusterClient, jarFiles List<URL>, classpaths List<URL>, userCodeClassLoader ClassLoader, savepointPath String) in class org.apache.flink.client.program.DetachedEnvironment |
From |
To |
|
Change Parameter Type yarnCluster : AbstractFlinkYarnCluster to yarnCluster : YarnClusterClient in method public runInteractiveCli(yarnCluster YarnClusterClient, readConsoleInput boolean) : void in class org.apache.flink.yarn.cli.FlinkYarnSessionCli |
From |
To |
|
Move Method public testManualOptionsOverridesYarn() : void from class org.apache.flink.client.CliFrontendAddressConfigurationTest to public testManualOptionsOverridesYarn() : void from class org.apache.flink.yarn.CliFrontendYarnAddressConfigurationTest |
From |
To |
|
Move Method public checkJobManagerAddress(config Configuration, expectedAddress String, expectedPort int) : void from class org.apache.flink.client.CliFrontendAddressConfigurationTest to private checkJobManagerAddress(config Configuration, expectedAddress String, expectedPort int) : void from class org.apache.flink.yarn.CliFrontendYarnAddressConfigurationTest |
From |
To |
|
Move Method public testInvalidYarnConfig() : void from class org.apache.flink.client.CliFrontendAddressConfigurationTest to public testInvalidYarnConfig() : void from class org.apache.flink.yarn.CliFrontendYarnAddressConfigurationTest |
From |
To |
|
Move Method public testYarnConfig() : void from class org.apache.flink.client.CliFrontendAddressConfigurationTest to public testYarnConfig() : void from class org.apache.flink.yarn.CliFrontendYarnAddressConfigurationTest |
From |
To |
|
Change Variable Type flinkYarnClient : AbstractFlinkYarnClient to flinkYarnDescriptor : YarnClusterDescriptor in method public testDynamicProperties() : void in class org.apache.flink.yarn.FlinkYarnSessionCliTest |
From |
To |
|
Change Variable Type status : boolean to status : ApplicationStatus in method public getApplicationStatus() : ApplicationStatus in class org.apache.flink.yarn.YarnClusterClient |
From |
To |
|
Change Variable Type client : Client to client : ClusterClient in method protected executeRemotely(streamGraph StreamGraph, jarFiles List<URL>) : JobExecutionResult in class org.apache.flink.streaming.api.environment.RemoteStreamEnvironment |
From |
To |
|
Change Variable Type out : Client to out : ClusterClient in method public shouldSubmitToJobClient() : void in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Variable Type client : Client to client : ClusterClient in method public submitTopologyWithOpts(name String, uploadedJarLocation String, topology FlinkTopology) : void in class org.apache.flink.storm.api.FlinkClient |
From |
To |
|
Change Variable Type out : Client to out : ClusterClient in method public shouldSubmitToJobClientFails() : void in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Variable Type out : Client to out : ClusterClient in method public testDetachedMode() : void in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Variable Type yarnCluster : AbstractFlinkYarnCluster to yarnCluster : ClusterClient in method public testJavaAPI() : void in class org.apache.flink.yarn.YARNSessionFIFOITCase |
From |
To |
|
Change Variable Type client : Client to client : ClusterClient in method public testExternalProgram() : void in class org.apache.flink.api.avro.AvroExternalJarProgramITCase |
From |
To |
|
Change Variable Type flinkYarnClient : TestingFlinkYarnClient to flinkYarnClient : TestingYarnClusterDescriptor in method public testMultipleAMKill() : void in class org.apache.flink.yarn.YARNHighAvailabilityITCase |
From |
To |
|
Change Variable Type yarnCluster : AbstractFlinkYarnCluster to yarnCluster : ClusterClient in method public testMultipleAMKill() : void in class org.apache.flink.yarn.YARNHighAvailabilityITCase |
From |
To |
|
Change Variable Type client : Client to client : ClusterClient in method public killTopologyWithOpts(name String, options KillOptions) : void in class org.apache.flink.storm.api.FlinkClient |
From |
To |
|
Rename Method public shutdown(failApplication boolean) : void renamed to public finalizeCluster() : void in class org.apache.flink.yarn.YarnClusterClient |
From |
To |
|
Rename Method public getYARNSessionCLIOptions(options Options) : void renamed to public addOptions(options Options) : void in class org.apache.flink.yarn.cli.FlinkYarnSessionCli |
From |
To |
|
Rename Method public hasBeenStopped() : boolean renamed to public hasBeenShutdown() : boolean in class org.apache.flink.yarn.YarnClusterClient |
From |
To |
|
Rename Method protected executeProgramDetached(program PackagedProgram, client Client, parallelism int) : int renamed to protected executeProgram(program PackagedProgram, client ClusterClient, parallelism int) : int in class org.apache.flink.client.CliFrontendRunTest.RunTestingCliFrontend |
From |
To |
|
Rename Method public hasFailed() : boolean renamed to public getApplicationStatus() : ApplicationStatus in class org.apache.flink.yarn.YarnClusterClient |
From |
To |
|
Rename Method protected executeProgramBlocking(program PackagedProgram, client Client, parallelism int) : int renamed to protected executeProgram(program PackagedProgram, client ClusterClient, parallelism int) : int in class org.apache.flink.client.CliFrontend |
From |
To |
|
Rename Method public abstract shutdown(failApplication boolean) : void renamed to protected abstract finalizeCluster() : void in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Rename Method public abstract getApplicationId() : String renamed to protected abstract getClusterIdentifier() : String in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Rename Method public getApplicationId() : String renamed to public getClusterIdentifier() : String in class org.apache.flink.yarn.YarnClusterClient |
From |
To |