|
Change Return Type StandaloneClusterClient to RestClusterClient<StandaloneClusterId> in method public retrieve(standaloneClusterId StandaloneClusterId) : RestClusterClient<StandaloneClusterId> in class org.apache.flink.client.deployment.StandaloneClusterDescriptor |
From |
To |
|
Change Return Type RestClusterClient<StandaloneClusterId> to StandaloneClusterClient in method public retrieve(standaloneClusterId StandaloneClusterId) : StandaloneClusterClient in class org.apache.flink.client.deployment.LegacyStandaloneClusterDescriptor |
From |
To |
|
Change Return Type StandaloneClusterClient to RestClusterClient<StandaloneClusterId> in method public deploySessionCluster(clusterSpecification ClusterSpecification) : RestClusterClient<StandaloneClusterId> in class org.apache.flink.client.deployment.StandaloneClusterDescriptor |
From |
To |
|
Change Return Type RestClusterClient<StandaloneClusterId> to StandaloneClusterClient in method public deployJobCluster(clusterSpecification ClusterSpecification, jobGraph JobGraph, detached boolean) : StandaloneClusterClient in class org.apache.flink.client.deployment.LegacyStandaloneClusterDescriptor |
From |
To |
|
Change Return Type RestClusterClient<StandaloneClusterId> to StandaloneClusterClient in method public deploySessionCluster(clusterSpecification ClusterSpecification) : StandaloneClusterClient in class org.apache.flink.client.deployment.LegacyStandaloneClusterDescriptor |
From |
To |
|
Change Return Type YarnClusterClient to ClusterClient<ApplicationId> in method public deployJobCluster(clusterSpecification ClusterSpecification, jobGraph JobGraph, detached boolean) : ClusterClient<ApplicationId> in class org.apache.flink.yarn.YarnClusterDescriptor |
From |
To |
|
Change Return Type Flip6StandaloneClusterDescriptor to LegacyStandaloneClusterDescriptor in method public createClusterDescriptor(commandLine CommandLine) : LegacyStandaloneClusterDescriptor in class org.apache.flink.client.cli.LegacyCLI |
From |
To |
|
Change Return Type StandaloneClusterClient to RestClusterClient<StandaloneClusterId> in method public deployJobCluster(clusterSpecification ClusterSpecification, jobGraph JobGraph, detached boolean) : RestClusterClient<StandaloneClusterId> in class org.apache.flink.client.deployment.StandaloneClusterDescriptor |
From |
To |
|
Change Return Type ClusterClient<ApplicationId> to YarnClusterClient in method public deployJobCluster(clusterSpecification ClusterSpecification, jobGraph JobGraph, detached boolean) : YarnClusterClient in class org.apache.flink.yarn.LegacyYarnClusterDescriptor |
From |
To |
|
Rename Attribute flip6 : boolean to isNewMode : boolean in class org.apache.flink.yarn.cli.FlinkYarnSessionCli |
From |
To |
|
Rename Attribute FLIP6_MODE : String to NEW_MODE : String in class org.apache.flink.configuration.CoreOptions |
From |
To |
|
Rename Attribute FLIP6_CODEBASE : String to NEW_CODEBASE : String in class org.apache.flink.test.util.MiniClusterResource |
From |
To |
|
Rename Attribute OLD_MODE : String to LEGACY_MODE : String in class org.apache.flink.configuration.CoreOptions |
From |
To |
|
Rename Attribute conf : Configuration to configuration : Configuration in class org.apache.flink.streaming.api.environment.LocalStreamEnvironment |
From |
To |
|
Rename Attribute flip6 : boolean to isNewMode : boolean in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Rename Attribute flip6 : boolean to isNewMode : boolean in class org.apache.flink.yarn.YarnTestBase |
From |
To |
|
Change Variable Type yarnClusterDescriptor : YarnClusterDescriptor to yarnClusterDescriptor : LegacyYarnClusterDescriptor in method public testYarnClientShutDown() : void in class org.apache.flink.yarn.YarnClusterDescriptorTest |
From |
To |
|
Change Variable Type flip6YarnClusterDescriptor : Flip6YarnClusterDescriptor to yarnClusterDescriptor : YarnClusterDescriptor in method public testPerJobMode() : void in class org.apache.flink.yarn.YARNITCase |
From |
To |
|
Change Variable Type clusterDescriptor : YarnClusterDescriptor to clusterDescriptor : LegacyYarnClusterDescriptor in method public testSetupApplicationMasterContainer() : void in class org.apache.flink.yarn.YarnClusterDescriptorTest |
From |
To |
|
Change Variable Type clusterDescriptor : YarnClusterDescriptor to clusterDescriptor : LegacyYarnClusterDescriptor in method public testFailIfTaskSlotsHigherThanMaxVcores() : void in class org.apache.flink.yarn.YarnClusterDescriptorTest |
From |
To |
|
Change Variable Type clusterDescriptor : YarnClusterDescriptor to clusterDescriptor : LegacyYarnClusterDescriptor in method public testConfigOverwrite() : void in class org.apache.flink.yarn.YarnClusterDescriptorTest |
From |
To |
|
Change Variable Type clusterDescriptor : Flip6YarnClusterDescriptor to clusterDescriptor : YarnClusterDescriptor in method public testFlinkContainerMemory() : void in class org.apache.flink.yarn.YarnConfigurationITCase |
From |
To |
|
Change Variable Type exec : LocalFlinkMiniCluster to miniCluster : MiniCluster in method public execute(jobName String) : JobExecutionResult in class org.apache.flink.streaming.api.environment.LocalStreamEnvironment |
From |
To |
|
Change Variable Type env : Flip6LocalStreamEnvironment to env : LocalStreamEnvironment in method public testMultipleJobsAfterAnother() : void in class org.apache.flink.streaming.api.environment.LocalStreamEnvironmentITCase |
From |
To |
|
Change Variable Type env : Flip6LocalStreamEnvironment to env : LocalStreamEnvironment in method public testRunIsolatedJob() : void in class org.apache.flink.streaming.api.environment.LocalStreamEnvironmentITCase |
From |
To |