|
Change Parameter Type executionConfig : ExecutionConfig to serializedExecutionConfig : SerializedValue<ExecutionConfig> in method public TaskDeploymentDescriptor(jobID JobID, vertexID JobVertexID, executionId ExecutionAttemptID, serializedExecutionConfig SerializedValue<ExecutionConfig>, taskName String, indexInSubtaskGroup int, numberOfSubtasks int, attemptNumber int, jobConfiguration Configuration, taskConfiguration Configuration, invokableClassName String, producedPartitions List<ResultPartitionDeploymentDescriptor>, inputGates List<InputGateDeploymentDescriptor>, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, targetSlotNumber int) in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Change Parameter Type config : ExecutionConfig to jobName : String in method public JobGraph(jobName String) in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Change Parameter Type executionConfig : ExecutionConfig to serializedExecutionConfig : SerializedValue<ExecutionConfig> in method public TaskDeploymentDescriptor(jobID JobID, vertexID JobVertexID, executionId ExecutionAttemptID, serializedExecutionConfig SerializedValue<ExecutionConfig>, taskName String, indexInSubtaskGroup int, numberOfSubtasks int, attemptNumber int, jobConfiguration Configuration, taskConfiguration Configuration, invokableClassName String, producedPartitions List<ResultPartitionDeploymentDescriptor>, inputGates List<InputGateDeploymentDescriptor>, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, targetSlotNumber int, operatorState SerializedValue<StateHandle<?>>, recoveryTimestamp long) in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Change Parameter Type config : ExecutionConfig to serializedConfig : SerializedValue<ExecutionConfig> in method package ExecutionGraph(executionContext ExecutionContext, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout FiniteDuration, restartStrategy RestartStrategy) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type config : ExecutionConfig to serializedConfig : SerializedValue<ExecutionConfig> in method public ExecutionGraph(executionContext ExecutionContext, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout FiniteDuration, restartStrategy RestartStrategy, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, userClassLoader ClassLoader) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Parameter Type config : ExecutionConfig to vertices : JobVertex... in method public JobGraph(jobName String, vertices JobVertex...) in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Rename Parameter executionConfig : ExecutionConfig to serializedExecutionConfig : SerializedValue<ExecutionConfig> in method public TaskDeploymentDescriptor(jobID JobID, vertexID JobVertexID, executionId ExecutionAttemptID, serializedExecutionConfig SerializedValue<ExecutionConfig>, taskName String, indexInSubtaskGroup int, numberOfSubtasks int, attemptNumber int, jobConfiguration Configuration, taskConfiguration Configuration, invokableClassName String, producedPartitions List<ResultPartitionDeploymentDescriptor>, inputGates List<InputGateDeploymentDescriptor>, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, targetSlotNumber int) in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Rename Parameter config : ExecutionConfig to jobName : String in method public JobGraph(jobName String) in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |
|
Rename Parameter executionConfig : ExecutionConfig to serializedExecutionConfig : SerializedValue<ExecutionConfig> in method public TaskDeploymentDescriptor(jobID JobID, vertexID JobVertexID, executionId ExecutionAttemptID, serializedExecutionConfig SerializedValue<ExecutionConfig>, taskName String, indexInSubtaskGroup int, numberOfSubtasks int, attemptNumber int, jobConfiguration Configuration, taskConfiguration Configuration, invokableClassName String, producedPartitions List<ResultPartitionDeploymentDescriptor>, inputGates List<InputGateDeploymentDescriptor>, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, targetSlotNumber int, operatorState SerializedValue<StateHandle<?>>, recoveryTimestamp long) in class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor |
From |
To |
|
Rename Parameter config : ExecutionConfig to serializedConfig : SerializedValue<ExecutionConfig> in method package ExecutionGraph(executionContext ExecutionContext, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout FiniteDuration, restartStrategy RestartStrategy) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Rename Parameter config : ExecutionConfig to serializedConfig : SerializedValue<ExecutionConfig> in method public ExecutionGraph(executionContext ExecutionContext, jobId JobID, jobName String, jobConfig Configuration, serializedConfig SerializedValue<ExecutionConfig>, timeout FiniteDuration, restartStrategy RestartStrategy, requiredJarFiles List<BlobKey>, requiredClasspaths List<URL>, userClassLoader ClassLoader) in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Rename Parameter config : ExecutionConfig to vertices : JobVertex... in method public JobGraph(jobName String, vertices JobVertex...) in class org.apache.flink.runtime.jobgraph.JobGraph |
From |
To |