flink aedbacfc553a7226bbf06410232fb2a2b315cf8b

aedbacfc553a7226bbf06410232fb2a2b315cf8b

Files Diff

Added: 2
Removed: 0
Renamed: 0
Modified: 11

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Rename Variable	1
	Rename Variable result : JobManagerMessages.ConsumerNotificationResult to futureResponse : Future<Object> in method private scheduleOrUpdateConsumers() : void in class org.apache.flink.runtime.io.network.partition.IntermediateResultPartition	From	To
	Change Return Type	4
	Change Return Type boolean to void in method package scheduleOrUpdateConsumers(consumers List<List<ExecutionEdge>>) : void in class org.apache.flink.runtime.executiongraph.Execution	From	To
	Change Return Type FiniteDuration to Timeout in method public getJobManagerTimeout() : Timeout in class org.apache.flink.runtime.io.network.NetworkEnvironment	From	To
	Change Return Type boolean to void in method package scheduleOrUpdateConsumers(partitionIndex int) : void in class org.apache.flink.runtime.executiongraph.ExecutionVertex	From	To
	Change Return Type boolean to void in method public scheduleOrUpdateConsumers(executionId ExecutionAttemptID, partitionIndex int) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph	From	To
	Change Variable Type	3
	Change Variable Type result : TaskManagerMessages.TaskOperationResult to result : TaskOperationResult in method private sendCancelRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution	From	To
	Change Variable Type result : JobManagerMessages.ConsumerNotificationResult to futureResponse : Future<Object> in method private scheduleOrUpdateConsumers() : void in class org.apache.flink.runtime.io.network.partition.IntermediateResultPartition	From	To
	Change Variable Type result : TaskManagerMessages.TaskOperationResult to result : TaskOperationResult in method public onComplete(failure Throwable, success Object) : void in class org.apache.flink.runtime.executiongraph.Execution.deployToSlot.onComplete	From	To