bf8c8e54094151348caedd3120931516f76c3cf3
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 38
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public testJobWithCustomInputFormat() : void renamed to public testJobsWithCustomClassLoader() : void in class org.apache.flink.test.classloading.ClassLoaderITCase | From | To | |
| Rename Variable | 1 | ||
| Rename Variable t : Throwable to throwable : Throwable in method public submitJobAndWait(actorSystem ActorSystem, jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, userCodeClassloader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.JobClient | From | To | |
| Change Return Type | 1 | ||
| Change Return Type SerializedJobExecutionResult to JobExecutionResult in method public submitJobAndWait(actorSystem ActorSystem, jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, userCodeClassloader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.JobClient | From | To | |
| Move Attribute | 2 | ||
| Move Attribute private cachedError : Throwable from class org.apache.flink.runtime.taskmanager.TaskExecutionState to private cachedError : Throwable from class org.apache.flink.runtime.util.SerializedThrowable | From | To | |
| Move Attribute private serializedError : byte[] from class org.apache.flink.runtime.taskmanager.TaskExecutionState to private serializedError : byte[] from class org.apache.flink.runtime.util.SerializedThrowable | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.runtime.util.SerializedThrowable from class org.apache.flink.runtime.taskmanager.TaskExecutionState | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute cluser : ForkableFlinkMiniCluster to cluster : ForkableFlinkMiniCluster in class org.apache.flink.test.failingPrograms.JobSubmissionFailsITCase | From | To | |
| Extract Variable | 1 | ||
| Extract Variable cl : ClassLoader in method private createOperatorWithContext(output List<String>, partitioner KeySelector<Integer,Serializable>, serializedState byte[]) : StreamMap<Integer,String> from class org.apache.flink.streaming.api.state.StatefulOperatorTest | From | To | |
| Inline Variable | 1 | ||
| Inline Variable serializedError : byte[] in method public TaskExecutionState(jobID JobID, executionId ExecutionAttemptID, executionState ExecutionState, error Throwable, accumulators AccumulatorSnapshot) from class org.apache.flink.runtime.taskmanager.TaskExecutionState | From | To |