|
Change Parameter Type remoteConnection : ClusterClient to remoteConnection : ClusterClient<?> 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 customCommandLines : Collection<CustomCommandLine> to customCommandLines : Collection<CustomCommandLine<?>> in method public printHelp(customCommandLines Collection<CustomCommandLine<?>>) : void in class org.apache.flink.client.cli.CliFrontendParser |
From |
To |
|
Change Parameter Type customCommandLines : Collection<CustomCommandLine> to customCommandLines : Collection<CustomCommandLine<?>> in method public printHelpForList(customCommandLines Collection<CustomCommandLine<?>>) : void in class org.apache.flink.client.cli.CliFrontendParser |
From |
To |
|
Change Parameter Type clusterClient : ClusterClient to clusterClient : ClusterClient<?> in method private disposeSavepoint(clusterClient ClusterClient<?>, savepointPath String) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Parameter Type remoteConnection : ClusterClient to remoteConnection : ClusterClient<?> 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 |
|
Change Parameter Type clusterClient : ClusterClient to clusterClient : ClusterClient<?> in method private runInteractiveCli(clusterClient ClusterClient<?>, yarnApplicationStatusMonitor YarnApplicationStatusMonitor, readConsoleInput boolean) : void in class org.apache.flink.yarn.cli.FlinkYarnSessionCli |
From |
To |
|
Change Parameter Type customCommandLines : Collection<CustomCommandLine> to customCommandLines : Collection<CustomCommandLine<?>> in method public printHelpForRun(customCommandLines Collection<CustomCommandLine<?>>) : void in class org.apache.flink.client.cli.CliFrontendParser |
From |
To |
|
Change Parameter Type customCommandLines : Collection<CustomCommandLine> to customCommandLines : Collection<CustomCommandLine<?>> in method public printHelpForSavepoint(customCommandLines Collection<CustomCommandLine<?>>) : void in class org.apache.flink.client.cli.CliFrontendParser |
From |
To |
|
Change Parameter Type customCommandLines : List<CustomCommandLine> to customCommandLines : List<CustomCommandLine<?>> in method public CliFrontend(configuration Configuration, customCommandLines List<CustomCommandLine<?>>) in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Parameter Type clusterClient : ClusterClient to clusterClient : ClusterClient<T> in method public DummyCustomCommandLine(clusterClient ClusterClient<T>) in class org.apache.flink.client.cli.util.DummyCustomCommandLine |
From |
To |
|
Change Parameter Type clusterId : String to clusterId : StandaloneClusterId in method public terminateCluster(clusterId StandaloneClusterId) : void in class org.apache.flink.client.deployment.Flip6StandaloneClusterDescriptor |
From |
To |
|
Change Parameter Type client : ClusterClient to client : ClusterClient<?> in method protected executeProgram(program PackagedProgram, client ClusterClient<?>, parallelism int) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Parameter Type customCommandLines : Collection<CustomCommandLine> to customCommandLines : Collection<CustomCommandLine<?>> in method public printHelpForStop(customCommandLines Collection<CustomCommandLine<?>>) : void in class org.apache.flink.client.cli.CliFrontendParser |
From |
To |
|
Change Parameter Type customCommandLines : Collection<CustomCommandLine> to customCommandLines : Collection<CustomCommandLine<?>> in method public printHelpForCancel(customCommandLines Collection<CustomCommandLine<?>>) : void in class org.apache.flink.client.cli.CliFrontendParser |
From |
To |
|
Change Parameter Type applicationID : String to standaloneClusterId : StandaloneClusterId in method public retrieve(standaloneClusterId StandaloneClusterId) : RestClusterClient<StandaloneClusterId> in class org.apache.flink.client.deployment.Flip6StandaloneClusterDescriptor |
From |
To |
|
Change Parameter Type client : ClusterClient to client : ClusterClient<?> 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 applicationID : String to clusterId : T in method public retrieve(clusterId T) : ClusterClient<T> in class org.apache.flink.client.deployment.ClusterDescriptor |
From |
To |
|
Change Parameter Type customCommandLines : Collection<CustomCommandLine> to customCommandLines : Collection<CustomCommandLine<?>> in method private printCustomCliOptions(customCommandLines Collection<CustomCommandLine<?>>, formatter HelpFormatter, runOptions boolean) : void in class org.apache.flink.client.cli.CliFrontendParser |
From |
To |
|
Change Parameter Type clusterId : String to clusterId : StandaloneClusterId in method public terminateCluster(clusterId StandaloneClusterId) : void in class org.apache.flink.client.deployment.StandaloneClusterDescriptor |
From |
To |
|
Change Parameter Type clusterId : String to clusterId : T in method public terminateCluster(clusterId T) : void in class org.apache.flink.client.cli.util.DummyClusterDescriptor |
From |
To |
|
Change Parameter Type clusterId : String to clusterId : T in method public terminateCluster(clusterId T) : void in class org.apache.flink.client.deployment.ClusterDescriptor |
From |
To |
|
Change Parameter Type applicationID : String to applicationId : ApplicationId in method public retrieve(applicationId ApplicationId) : YarnClusterClient in class org.apache.flink.yarn.AbstractYarnClusterDescriptor |
From |
To |
|
Change Parameter Type clusterClient : ClusterClient to clusterClient : ClusterClient<?> in method private triggerSavepoint(clusterClient ClusterClient<?>, jobId JobID, savepointDirectory String) : String in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Parameter Type clusterClient : ClusterClient to clusterClient : ClusterClient<T> in method public DummyClusterDescriptor(clusterClient ClusterClient<T>) in class org.apache.flink.client.cli.util.DummyClusterDescriptor |
From |
To |
|
Change Parameter Type applicationID : String to standaloneClusterId : StandaloneClusterId in method public retrieve(standaloneClusterId StandaloneClusterId) : StandaloneClusterClient in class org.apache.flink.client.deployment.StandaloneClusterDescriptor |
From |
To |
|
Change Parameter Type applicationID : String to clusterId : T in method public retrieve(clusterId T) : ClusterClient<T> in class org.apache.flink.client.cli.util.DummyClusterDescriptor |
From |
To |
|
Change Parameter Type reject : boolean to exception : Exception in method private createClusterClient(exception Exception) : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendStopTest |
From |
To |
|
Change Return Type RestClusterClient to RestClusterClient<StandaloneClusterId> in method public deployJobCluster(clusterSpecification ClusterSpecification, jobGraph JobGraph) : RestClusterClient<StandaloneClusterId> in class org.apache.flink.client.deployment.Flip6StandaloneClusterDescriptor |
From |
To |
|
Change Return Type RestClusterClient to RestClusterClient<StandaloneClusterId> in method public retrieve(standaloneClusterId StandaloneClusterId) : RestClusterClient<StandaloneClusterId> in class org.apache.flink.client.deployment.Flip6StandaloneClusterDescriptor |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<String> in method private createClusterClient(exception Exception) : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendStopTest |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<T> in method public deployJobCluster(clusterSpecification ClusterSpecification, jobGraph JobGraph) : ClusterClient<T> in class org.apache.flink.client.cli.util.DummyClusterDescriptor |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<String> in method private createClusterClient(expectedResponse String) : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Return Type List<CustomCommandLine> to List<CustomCommandLine<?>> in method public loadCustomCommandLines(configuration Configuration, configurationDirectory String) : List<CustomCommandLine<?>> in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Return Type ClusterDescriptor to Flip6StandaloneClusterDescriptor in method public createClusterDescriptor(commandLine CommandLine) : Flip6StandaloneClusterDescriptor in class org.apache.flink.client.cli.Flip6DefaultCLI |
From |
To |
|
Change Return Type ClusterClient to YarnClusterClient in method public retrieve(applicationId ApplicationId) : YarnClusterClient in class org.apache.flink.yarn.AbstractYarnClusterDescriptor |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<String> in method private createClusterClient() : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendListTest |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<T> in method public deployJobCluster(clusterSpecification ClusterSpecification, jobGraph JobGraph) : ClusterClient<T> in class org.apache.flink.client.deployment.ClusterDescriptor |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<String> in method private createClusterClient() : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendCancelTest |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<String> in method private createFailingClusterClient(expectedException Exception) : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Return Type String to StandaloneClusterId in method public getClusterId(commandLine CommandLine) : StandaloneClusterId in class org.apache.flink.client.cli.DefaultCLI |
From |
To |
|
Change Return Type ClusterDescriptor to ClusterDescriptor<T> in method public createClusterDescriptor(commandLine CommandLine) : ClusterDescriptor<T> in class org.apache.flink.client.cli.CustomCommandLine |
From |
To |
|
Change Return Type CustomCommandLine to CustomCommandLine<?> in method public getActiveCustomCommandLine(commandLine CommandLine) : CustomCommandLine<?> in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<?> in method public getClient() : ClusterClient<?> in class org.apache.flink.client.program.ContextEnvironment |
From |
To |
|
Change Return Type RestClusterClient to RestClusterClient<StandaloneClusterId> in method public deploySessionCluster(clusterSpecification ClusterSpecification) : RestClusterClient<StandaloneClusterId> in class org.apache.flink.client.deployment.Flip6StandaloneClusterDescriptor |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<T> in method public deploySessionCluster(clusterSpecification ClusterSpecification) : ClusterClient<T> in class org.apache.flink.client.cli.util.DummyClusterDescriptor |
From |
To |
|
Change Return Type ClusterDescriptor to StandaloneClusterDescriptor in method public createClusterDescriptor(commandLine CommandLine) : StandaloneClusterDescriptor in class org.apache.flink.client.cli.DefaultCLI |
From |
To |
|
Change Return Type String to ApplicationId in method public getClusterId(commandLine CommandLine) : ApplicationId in class org.apache.flink.yarn.cli.FlinkYarnSessionCli |
From |
To |
|
Change Return Type ClusterDescriptor to ClusterDescriptor<T> in method public createClusterDescriptor(commandLine CommandLine) : ClusterDescriptor<T> in class org.apache.flink.client.cli.util.DummyCustomCommandLine |
From |
To |
|
Change Return Type String to T in method public getClusterId(commandLine CommandLine) : T in class org.apache.flink.client.cli.CustomCommandLine |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<T> in method public retrieve(clusterId T) : ClusterClient<T> in class org.apache.flink.client.deployment.ClusterDescriptor |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<T> in method public deploySessionCluster(clusterSpecification ClusterSpecification) : ClusterClient<T> in class org.apache.flink.client.deployment.ClusterDescriptor |
From |
To |
|
Change Return Type ClusterClient to ClusterClient<T> in method public retrieve(clusterId T) : ClusterClient<T> in class org.apache.flink.client.cli.util.DummyClusterDescriptor |
From |
To |
|
Change Return Type CustomCommandLine to CustomCommandLine<?> in method private loadCustomCommandLine(className String, params Object...) : CustomCommandLine<?> in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Return Type String to StandaloneClusterId in method public getClusterId(commandLine CommandLine) : StandaloneClusterId in class org.apache.flink.client.cli.Flip6DefaultCLI |
From |
To |
|
Change Variable Type clusterId : String to clusterId : ApplicationId in method public testYarnIDOverridesPropertiesFile() : void in class org.apache.flink.yarn.FlinkYarnSessionCliTest |
From |
To |
|
Change Variable Type client : ClusterClient to client : ClusterClient<StandaloneClusterId> in method public testNonExistingJobRetrieval() : void in class org.apache.flink.test.example.client.JobRetrievalITCase |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<ApplicationId> in method public run(args String[]) : int in class org.apache.flink.yarn.cli.FlinkYarnSessionCli |
From |
To |
|
Change Variable Type client : ClusterClient to client : StandaloneClusterClient in method private testFailureBehavior(unreachableEndpoint InetSocketAddress) : void in class org.apache.flink.client.program.ClientConnectionTest |
From |
To |
|
Change Variable Type activeCommandLine : CustomCommandLine to activeCommandLine : CustomCommandLine<?> in method protected cancel(args String[]) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterId : String to clusterId : ApplicationId in method public testResumeFromYarnPropertiesFile() : void in class org.apache.flink.yarn.FlinkYarnSessionCliTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method public testList() : void in class org.apache.flink.client.cli.CliFrontendListTest |
From |
To |
|
Change Variable Type customCommandLine : CustomCommandLine to customCommandLine : CustomCommandLine<?> in method public CliFrontend(configuration Configuration, customCommandLines List<CustomCommandLine<?>>) in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<T> in method private runClusterAction(activeCommandLine CustomCommandLine<T>, commandLine CommandLine, clusterAction ClusterAction<T>) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type client : ClusterClient to client : StandaloneClusterClient in method public killTopologyWithOpts(name String, options KillOptions) : void in class org.apache.flink.storm.api.FlinkClient |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method public testTriggerSavepointSuccess() : void in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method public testTriggerSavepointFailure() : void in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<?> in method public testManualConfigurationOverride() : void in class org.apache.flink.client.cli.DefaultCLITest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : TestClusterClient in method public testClusterClientCancelWithSavepoint() : void in class org.apache.flink.client.program.ClusterClientTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method public testCancelWithSavepoint() : void in class org.apache.flink.client.cli.CliFrontendCancelTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : DisposeSavepointClusterClient in method public testDisposeWithJar() : void in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method public testTriggerSavepointCustomTarget() : void in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Variable Type client : ClusterClient to client : StandaloneClusterClient in method public submitTopologyWithOpts(name String, uploadedJarLocation String, topology FlinkTopology) : void in class org.apache.flink.storm.api.FlinkClient |
From |
To |
|
Change Variable Type client : ClusterClient to clusterClient : ClusterClient<T> in method private runClusterAction(activeCommandLine CustomCommandLine<T>, commandLine CommandLine, clusterAction ClusterAction<T>) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type client : ClusterClient to client : StandaloneClusterClient in method protected executeRemotely(streamGraph StreamGraph, jarFiles List<URL>) : JobExecutionResult in class org.apache.flink.streaming.api.environment.RemoteStreamEnvironment |
From |
To |
|
Change Variable Type clusterDescriptor : ClusterDescriptor to clusterDescriptor : StandaloneClusterDescriptor in method public testManualConfigurationOverride() : void in class org.apache.flink.client.cli.DefaultCLITest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : TestClusterClient in method public testDisposeSavepointUnknownResponse() : void in class org.apache.flink.client.program.ClusterClientTest |
From |
To |
|
Change Variable Type clusterId : String to clusterId : ApplicationId in method public testResumeFromYarnID() : void in class org.apache.flink.yarn.FlinkYarnSessionCliTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : TestClusterClient in method public testDisposeClassNotFoundException() : void in class org.apache.flink.client.program.ClusterClientTest |
From |
To |
|
Change Variable Type clusterDescriptor : ClusterDescriptor to clusterDescriptor : StandaloneClusterDescriptor in method public testConfigurationPassing() : void in class org.apache.flink.client.cli.DefaultCLITest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method private createFailingClusterClient(expectedException Exception) : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Variable Type customCommandLine : CustomCommandLine to activeCommandLine : CustomCommandLine<?> in method protected savepoint(args String[]) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type customCommandLine : CustomCommandLine to activeCommandLine : CustomCommandLine<T> in method private runClusterAction(activeCommandLine CustomCommandLine<T>, commandLine CommandLine, clusterAction ClusterAction<T>) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type activeCommandLine : CustomCommandLine to activeCommandLine : CustomCommandLine<?> in method protected stop(args String[]) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method private createClusterClient() : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendListTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : StandaloneClusterClient in method public testClusterClientShutdown() : void in class org.apache.flink.client.program.ClusterClientTest |
From |
To |
|
Change Variable Type out : ClusterClient to out : StandaloneClusterClient in method public shouldSubmitToJobClientFails() : void in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Variable Type out : ClusterClient to out : StandaloneClusterClient in method public shouldSubmitToJobClient() : void in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Variable Type clusterDescriptor : ClusterDescriptor to clusterDescriptor : ClusterDescriptor<T> in method private runProgram(customCommandLine CustomCommandLine<T>, commandLine CommandLine, runOptions RunOptions, program PackagedProgram) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : TestClusterClient in method public testClusterClientCancel() : void in class org.apache.flink.client.program.ClusterClientTest |
From |
To |
|
Change Variable Type activeCommandLine : CustomCommandLine to activeCommandLine : CustomCommandLine<?> in method protected list(args String[]) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : DisposeSavepointClusterClient in method public testDisposeSavepointFailure() : void in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Variable Type out : ClusterClient to out : StandaloneClusterClient in method public testDetachedMode() : void in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Variable Type cli : CustomCommandLine to cli : CustomCommandLine<?> in method public getActiveCustomCommandLine(commandLine CommandLine) : CustomCommandLine<?> in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type yarnCluster : ClusterClient to yarnCluster : ClusterClient<ApplicationId> in method public testJavaAPI() : void in class org.apache.flink.yarn.YARNSessionFIFOITCase |
From |
To |
|
Change Variable Type customCommandLines : List<CustomCommandLine> to customCommandLines : List<CustomCommandLine<?>> in method public loadCustomCommandLines(configuration Configuration, configurationDirectory String) : List<CustomCommandLine<?>> in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method public testUnknownJobId() : void in class org.apache.flink.client.cli.CliFrontendStopTest |
From |
To |
|
Change Variable Type applicationId : String to applicationId : ApplicationId in method protected applyCommandLineOptionsToConfiguration(commandLine CommandLine) : Configuration in class org.apache.flink.yarn.cli.FlinkYarnSessionCli |
From |
To |
|
Change Variable Type yarnCluster : ClusterClient to yarnCluster : ClusterClient<ApplicationId> in method public testMultipleAMKill() : void in class org.apache.flink.yarn.YARNHighAvailabilityITCase |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method private createClusterClient(exception Exception) : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendStopTest |
From |
To |
|
Change Variable Type customCommandLines : List<CustomCommandLine> to customCommandLines : List<CustomCommandLine<?>> in method public main(args String[]) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method private createClusterClient() : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendCancelTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<?> in method public testConfigurationPassing() : void in class org.apache.flink.client.cli.DefaultCLITest |
From |
To |
|
Change Variable Type clusterId : String to clusterId : T in method private runProgram(customCommandLine CustomCommandLine<T>, commandLine CommandLine, runOptions RunOptions, program PackagedProgram) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterId : String to clusterId : T in method private runClusterAction(activeCommandLine CustomCommandLine<T>, commandLine CommandLine, clusterAction ClusterAction<T>) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method public testCancel() : void in class org.apache.flink.client.cli.CliFrontendCancelTest |
From |
To |
|
Change Variable Type client : ClusterClient to client : ClusterClient<StandaloneClusterId> in method public testJobRetrieval() : void in class org.apache.flink.test.example.client.JobRetrievalITCase |
From |
To |
|
Change Variable Type clusterDescriptor : ClusterDescriptor to clusterDescriptor : ClusterDescriptor<T> in method private runClusterAction(activeCommandLine CustomCommandLine<T>, commandLine CommandLine, clusterAction ClusterAction<T>) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type client : ClusterClient to client : StandaloneClusterClient in method public tryLocalExecution() : void in class org.apache.flink.client.program.ClientTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : TestClusterClient in method public testClusterClientList() : void in class org.apache.flink.client.program.ClusterClientTest |
From |
To |
|
Change Variable Type client : ClusterClient to client : StandaloneClusterClient in method public testJobManagerRetrievalWithHAServices() : void in class org.apache.flink.client.program.ClientConnectionTest |
From |
To |
|
Change Variable Type client : ClusterClient to client : ClusterClient<T> in method private runProgram(customCommandLine CustomCommandLine<T>, commandLine CommandLine, runOptions RunOptions, program PackagedProgram) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : TestClusterClient in method public testClusterClientSavepoint() : void in class org.apache.flink.client.program.ClusterClientTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : ClusterClient<String> in method private createClusterClient(expectedResponse String) : ClusterClient<String> in class org.apache.flink.client.cli.CliFrontendSavepointTest |
From |
To |
|
Change Variable Type clusterClient : ClusterClient to clusterClient : TestClusterClient in method public testClusterClientStop() : void in class org.apache.flink.client.program.ClusterClientTest |
From |
To |
|
Change Variable Type customCommandLine : CustomCommandLine to customCommandLine : CustomCommandLine<?> in method protected run(args String[]) : void in class org.apache.flink.client.cli.CliFrontend |
From |
To |