2bba2b3f0447be1802872a19344008cffb997b2b
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Extract Variable | 2 | ||
Extract Variable message : ExecutionGraphMessages.JobStatusChanged in method private notifyJobStatusChange(newState JobStatus, error Throwable) : void from class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To | |
Extract Variable actorMessage : ExecutionGraphMessages.ExecutionStateChanged in method package notifyExecutionChange(vertexId JobVertexID, subtask int, executionID ExecutionAttemptID, newExecutionState ExecutionState, error Throwable) : void from class org.apache.flink.runtime.executiongraph.ExecutionGraph | From | To |