|
Change Parameter Type jarFiles : List<String> to jarFiles : List<URL> in method public RemoteExecutor(inet InetSocketAddress, clientConfiguration Configuration, jarFiles List<URL>, globalClasspaths List<URL>) in class org.apache.flink.client.RemoteExecutor |
From |
To |
|
Change Parameter Type jarFiles : List<String> to jarFiles : List<URL> in method public JobWithJars(plan Plan, jarFiles List<URL>, classpaths List<URL>) in class org.apache.flink.client.program.JobWithJars |
From |
To |
|
Change Parameter Type jarFiles : List<File> to jarFiles : List<URL> in method private getJobGraph(optPlan FlinkPlan, jarFiles List<URL>, classpaths List<URL>) : JobGraph in class org.apache.flink.client.program.Client |
From |
To |
|
Change Parameter Type jarFiles : List<String> to jarFiles : List<URL> in method public RemoteExecutor(hostname String, port int, clientConfiguration Configuration, jarFiles List<URL>, globalClasspaths List<URL>) in class org.apache.flink.client.RemoteExecutor |
From |
To |
|
Change Parameter Type jarFiles : List<File> to jarFiles : List<URL> in method public ContextEnvironment(remoteConnection Client, jarFiles List<URL>, classpaths List<URL>, userCodeClassLoader ClassLoader, wait boolean) in class org.apache.flink.client.program.ContextEnvironment |
From |
To |
|
Change Parameter Type jarfile : File to jarfile : URL in method private checkJarFile(jarfile URL) : void in class org.apache.flink.client.program.PackagedProgram |
From |
To |
|
Change Parameter Type libraries : List<File> to libraries : List<URL> in method public runBlocking(compiledPlan OptimizedPlan, libraries List<URL>, classpaths List<URL>, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.client.program.Client |
From |
To |
|
Change Parameter Type jarFile : String to jarFile : URL in method public RemoteExecutor(hostport String, clientConfiguration Configuration, jarFile URL) in class org.apache.flink.client.RemoteExecutor |
From |
To |
|
Change Parameter Type jarFile : String to jarFile : URL in method public RemoteExecutor(hostname String, port int, jarFile URL) in class org.apache.flink.client.RemoteExecutor |
From |
To |
|
Change Parameter Type jarFiles : String... to jarFiles : URL[] in method public createRemoteExecutor(hostname String, port int, clientConfiguration Configuration, jarFiles URL[], globalClasspaths URL[]) : PlanExecutor in class org.apache.flink.api.common.PlanExecutor |
From |
To |
|
Change Parameter Type jarFilesToAttach : List<File> to jarFilesToAttach : List<URL> in method public ContextEnvironmentFactory(client Client, jarFilesToAttach List<URL>, classpathsToAttach List<URL>, userCodeClassLoader ClassLoader, defaultParallelism int, wait boolean) in class org.apache.flink.client.program.ContextEnvironment.ContextEnvironmentFactory |
From |
To |
|
Change Parameter Type jarFile : String to jarFile : URL in method public RemoteExecutor(hostname String, port int, clientConfiguration Configuration, jarFile URL) in class org.apache.flink.client.RemoteExecutor |
From |
To |
|
Change Parameter Type jarFile : String to jarFile : URL in method public JobWithJars(plan Plan, jarFile URL) in class org.apache.flink.client.program.JobWithJars |
From |
To |
|
Change Parameter Type jarFiles : List<File> to jarFiles : List<URL> in method package JobWithJars(plan Plan, jarFiles List<URL>, classpaths List<URL>, userCodeClassLoader ClassLoader) in class org.apache.flink.client.program.JobWithJars |
From |
To |
|
Change Parameter Type jars : List<File> to jars : List<URL> in method private createContextEnvironment(client Client, jars List<URL>, classpaths List<URL>, parallelism int, wait boolean) : StreamExecutionEnvironment in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Parameter Type jars : List<File> to jars : List<URL> in method protected StreamContextEnvironment(client Client, jars List<URL>, classpaths List<URL>, parallelism int, wait boolean) in class org.apache.flink.streaming.api.environment.StreamContextEnvironment |
From |
To |
|
Change Parameter Type libraries : List<File> to libraries : List<URL> in method public runDetached(compiledPlan OptimizedPlan, libraries List<URL>, classpaths List<URL>, classLoader ClassLoader) : JobSubmissionResult in class org.apache.flink.client.program.Client |
From |
To |
|
Change Parameter Type jarFile : String to jarFile : URL in method public RemoteExecutor(hostport String, jarFile URL) in class org.apache.flink.client.RemoteExecutor |
From |
To |
|
Change Parameter Type jarFile : File to jarFile : URL in method private extractContainedLibaries(jarFile URL) : List<File> in class org.apache.flink.client.program.PackagedProgram |
From |
To |
|
Change Parameter Type jarFile : File to jarFile : URL in method private getEntryPointClassNameFromJar(jarFile URL) : String in class org.apache.flink.client.program.PackagedProgram |
From |
To |
|
Change Parameter Type jarFilesToAttach : List<File> to jarFilesToAttach : List<URL> in method package setAsContext(client Client, jarFilesToAttach List<URL>, classpathsToAttach List<URL>, userCodeClassLoader ClassLoader, defaultParallelism int, wait boolean) : void in class org.apache.flink.client.program.ContextEnvironment |
From |
To |
|
Change Variable Type file : File to file : URL in method public execute(jobName String) : JobExecutionResult in class org.apache.flink.streaming.api.environment.StreamContextEnvironment |
From |
To |
|
Change Variable Type uploadedJarFile : File to uploadedJarUrl : URL in method public submitTopologyWithOpts(name String, uploadedJarLocation String, topology FlinkTopology) : void in class org.apache.flink.storm.api.FlinkClient |
From |
To |
|
Change Variable Type libs : List<File> to libs : List<URL> in method public getAllLibraries() : List<URL> in class org.apache.flink.client.program.PackagedProgram |
From |
To |
|
Change Variable Type files : List<String> to files : List<URL> in method public createRemoteExecutor(hostname String, port int, clientConfiguration Configuration, jarFiles URL[], globalClasspaths URL[]) : PlanExecutor in class org.apache.flink.api.common.PlanExecutor |
From |
To |
|
Change Variable Type file : File to jarFile : URL in method public JobWithJars(plan Plan, jarFile URL) in class org.apache.flink.client.program.JobWithJars |
From |
To |
|
Change Variable Type alljars : List<String> to alljars : List<URL> in method public execute(jobName String) : JobExecutionResult in class org.apache.flink.api.java.ScalaShellRemoteEnvironment |
From |
To |
|
Change Variable Type jar : File to jar : URL in method private getJobGraph(optPlan FlinkPlan, jarFiles List<URL>, classpaths List<URL>) : JobGraph in class org.apache.flink.client.program.Client |
From |
To |
|
Change Variable Type options : InfoOptions to options : RunOptions in method public testPlanWithExternalClass() : void in class org.apache.flink.client.CliFrontendPackageProgramTest |
From |
To |
|
Change Variable Type file : File to jarFile : URL in method private executeRemotely(jobGraph JobGraph) : JobExecutionResult in class org.apache.flink.streaming.api.environment.RemoteStreamEnvironment |
From |
To |