|
Change Parameter Type partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, networkEnvironment NetworkEnvironment, consumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) : Task in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Parameter Type partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, networkEnvironment NetworkEnvironment, consumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor, taskManagerConfig Configuration, execConfig ExecutionConfig) : Task in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Parameter Type partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method public Task(jobInformation JobInformation, taskInformation TaskInformation, executionAttemptID ExecutionAttemptID, subtaskIndex int, attemptNumber int, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>, targetSlotNumber int, taskStateHandles TaskStateHandles, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerConnection TaskManagerConnection, inputSplitProvider InputSplitProvider, checkpointResponder CheckpointResponder, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo, metricGroup TaskMetricGroup, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Rename Variable partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method public createTask(invokable Class<? extends AbstractInvokable>, taskConfig StreamConfig, taskManagerConfig Configuration) : Task in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Rename Variable partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method private createTask() : Task in class org.apache.flink.runtime.taskmanager.TaskAsyncCallTest |
From |
To |
|
Rename Variable partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, config Configuration, execConfig ExecutionConfig) : Task in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Rename Variable partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method public testExecutionFailsInNetworkRegistration() : void in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Variable Type partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method private createTask() : Task in class org.apache.flink.runtime.taskmanager.TaskAsyncCallTest |
From |
To |
|
Change Variable Type partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, config Configuration, execConfig ExecutionConfig) : Task in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Variable Type partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method public testExecutionFailsInNetworkRegistration() : void in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Variable Type partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method public createTask(invokable Class<? extends AbstractInvokable>, taskConfig StreamConfig, taskManagerConfig Configuration) : Task in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Rename Parameter partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, networkEnvironment NetworkEnvironment, consumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) : Task in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Rename Parameter partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager, networkEnvironment NetworkEnvironment, consumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor, taskManagerConfig Configuration, execConfig ExecutionConfig) : Task in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Rename Parameter partitionState : ExecutionState to producerState : ExecutionState in method package onPartitionStateUpdate(intermediateDataSetId IntermediateDataSetID, resultPartitionId ResultPartitionID, producerState ExecutionState) : void in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Rename Parameter partitionStateChecker : PartitionStateChecker to partitionProducerStateChecker : PartitionProducerStateChecker in method public Task(jobInformation JobInformation, taskInformation TaskInformation, executionAttemptID ExecutionAttemptID, subtaskIndex int, attemptNumber int, resultPartitionDeploymentDescriptors Collection<ResultPartitionDeploymentDescriptor>, inputGateDeploymentDescriptors Collection<InputGateDeploymentDescriptor>, targetSlotNumber int, taskStateHandles TaskStateHandles, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerConnection TaskManagerConnection, inputSplitProvider InputSplitProvider, checkpointResponder CheckpointResponder, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo, metricGroup TaskMetricGroup, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier, partitionProducerStateChecker PartitionProducerStateChecker, executor Executor) in class org.apache.flink.runtime.taskmanager.Task |
From |
To |
|
Rename Parameter resultId : IntermediateDataSetID to intermediateDataSetId : IntermediateDataSetID in method package onPartitionStateUpdate(intermediateDataSetId IntermediateDataSetID, resultPartitionId ResultPartitionID, producerState ExecutionState) : void in class org.apache.flink.runtime.taskmanager.Task |
From |
To |