flink fa2bb8f119f747a24bb013a4387ded5c51348ee7

fa2bb8f119f747a24bb013a4387ded5c51348ee7

Files Diff

Added: 14
Removed: 5
Renamed: 0
Modified: 36

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Method	1
Rename Method public tearDown() : void renamed to public copyOnTravis() : void in class org.apache.flink.yarn.YarnTestBase	From	To
Pull Up Method	27
Pull Up Method public getClusterDescription() : String from class org.apache.flink.yarn.FlinkYarnClient to public getClusterDescription() : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setShipFiles(shipFiles List<File>) : void from class org.apache.flink.yarn.FlinkYarnClient to public setShipFiles(shipFiles List<File>) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setDetachedMode(detachedMode boolean) : void from class org.apache.flink.yarn.FlinkYarnClient to public setDetachedMode(detachedMode boolean) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setConfigurationDirectory(configurationDirectory String) : void from class org.apache.flink.yarn.FlinkYarnClient to public setConfigurationDirectory(configurationDirectory String) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setLocalJarPath(localJarPath Path) : void from class org.apache.flink.yarn.FlinkYarnClient to public setLocalJarPath(localJarPath Path) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setStreamingMode(streamingMode boolean) : void from class org.apache.flink.yarn.FlinkYarnClient to public setStreamingMode(streamingMode boolean) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public deploy() : AbstractFlinkYarnCluster from class org.apache.flink.yarn.FlinkYarnClient to public deploy() : AbstractFlinkYarnCluster from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setFlinkConfigurationObject(conf Configuration) : void from class org.apache.flink.yarn.FlinkYarnClient to public setFlinkConfigurationObject(conf Configuration) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public allocateResource(nodeManagers int[], toAllocate int) : boolean from class org.apache.flink.yarn.FlinkYarnClient to public allocateResource(nodeManagers int[], toAllocate int) : boolean from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setTaskManagerMemory(memoryMb int) : void from class org.apache.flink.yarn.FlinkYarnClient to public setTaskManagerMemory(memoryMb int) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setName(name String) : void from class org.apache.flink.yarn.FlinkYarnClient to public setName(name String) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public getTaskManagerSlots() : int from class org.apache.flink.yarn.FlinkYarnClient to public getTaskManagerSlots() : int from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public getTaskManagerCount() : int from class org.apache.flink.yarn.FlinkYarnClient to public getTaskManagerCount() : int from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setTaskManagerCount(tmCount int) : void from class org.apache.flink.yarn.FlinkYarnClient to public setTaskManagerCount(tmCount int) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public getSessionFilesDir() : String from class org.apache.flink.yarn.FlinkYarnClient to public getSessionFilesDir() : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public getDynamicPropertiesEncoded() : String from class org.apache.flink.yarn.FlinkYarnClient to public getDynamicPropertiesEncoded() : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public isDetached() : boolean from class org.apache.flink.yarn.FlinkYarnClient to public isDetached() : boolean from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setDynamicPropertiesEncoded(dynamicPropertiesEncoded String) : void from class org.apache.flink.yarn.FlinkYarnClient to public setDynamicPropertiesEncoded(dynamicPropertiesEncoded String) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method private failSessionDuringDeployment() : void from class org.apache.flink.yarn.FlinkYarnClient to private failSessionDuringDeployment() : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setQueue(queue String) : void from class org.apache.flink.yarn.FlinkYarnClient to public setQueue(queue String) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public getFlinkLoggingConfigurationPath() : Path from class org.apache.flink.yarn.FlinkYarnClient to public getFlinkLoggingConfigurationPath() : Path from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setJobManagerMemory(memoryMb int) : void from class org.apache.flink.yarn.FlinkYarnClient to public setJobManagerMemory(memoryMb int) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method protected deployInternal() : AbstractFlinkYarnCluster from class org.apache.flink.yarn.FlinkYarnClient to protected deployInternal() : AbstractFlinkYarnCluster from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method private getCurrentFreeClusterResources(yarnClient YarnClient) : ClusterResourceDescription from class org.apache.flink.yarn.FlinkYarnClient to private getCurrentFreeClusterResources(yarnClient YarnClient) : ClusterResourceDescription from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setConfigurationFilePath(confPath Path) : void from class org.apache.flink.yarn.FlinkYarnClient to public setConfigurationFilePath(confPath Path) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setTaskManagerSlots(slots int) : void from class org.apache.flink.yarn.FlinkYarnClient to public setTaskManagerSlots(slots int) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Method public setFlinkLoggingConfigurationPath(logConfPath Path) : void from class org.apache.flink.yarn.FlinkYarnClient to public setFlinkLoggingConfigurationPath(logConfPath Path) : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Move And Rename Method	2
Move And Rename Method public FlinkYarnClient() from class org.apache.flink.yarn.FlinkYarnClient to public FlinkYarnClientBase() from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Move And Rename Method public isReadyForDepoyment() : void from class org.apache.flink.yarn.FlinkYarnClient to public isReadyForDeployment() : void from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Move Method	4
Move Method public illegalArgumentNegative() : void from class org.apache.flink.yarn.UtilsTests to public illegalArgumentNegative() : void from class org.apache.flink.yarn.UtilsTest	From	To
Move Method public tooMuchCutoff() : void from class org.apache.flink.yarn.UtilsTests to public tooMuchCutoff() : void from class org.apache.flink.yarn.UtilsTest	From	To
Move Method public illegalArgument() : void from class org.apache.flink.yarn.UtilsTests to public illegalArgument() : void from class org.apache.flink.yarn.UtilsTest	From	To
Move Method public testHeapCutoff() : void from class org.apache.flink.yarn.UtilsTests to public testHeapCutoff() : void from class org.apache.flink.yarn.UtilsTest	From	To
Rename Variable	1
Rename Variable flinkConfFilePath : File to flinkConfDirPath : File in method public startYARNWithConfig(conf Configuration) : void in class org.apache.flink.yarn.YarnTestBase	From	To
Move Source Folder	1
Move Source Folder flink-yarn/src/test to flink-yarn-tests/src/main	From	To
Pull Up Attribute	33
Pull Up Attribute public ENV_TM_MEMORY : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_TM_MEMORY : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private flinkJarPath : Path from class org.apache.flink.yarn.FlinkYarnClient to private flinkJarPath : Path from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_CLIENT_USERNAME : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_CLIENT_USERNAME : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_APP_ID : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_APP_ID : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_SLOTS : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_SLOTS : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private slots : int from class org.apache.flink.yarn.FlinkYarnClient to private slots : int from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private detached : boolean from class org.apache.flink.yarn.FlinkYarnClient to private detached : boolean from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private yarnQueue : String from class org.apache.flink.yarn.FlinkYarnClient to private yarnQueue : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private taskManagerCount : int from class org.apache.flink.yarn.FlinkYarnClient to private taskManagerCount : int from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private flinkLoggingConfigurationPath : Path from class org.apache.flink.yarn.FlinkYarnClient to private flinkLoggingConfigurationPath : Path from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private flinkConfiguration : org.apache.flink.configuration.Configuration from class org.apache.flink.yarn.FlinkYarnClient to private flinkConfiguration : org.apache.flink.configuration.Configuration from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private dynamicPropertiesEncoded : String from class org.apache.flink.yarn.FlinkYarnClient to private dynamicPropertiesEncoded : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private yarnClient : YarnClient from class org.apache.flink.yarn.FlinkYarnClient to private yarnClient : YarnClient from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private sessionFilesDir : Path from class org.apache.flink.yarn.FlinkYarnClient to private sessionFilesDir : Path from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private LOG : Logger from class org.apache.flink.yarn.FlinkYarnClient to private LOG : Logger from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private shipFiles : List<File> from class org.apache.flink.yarn.FlinkYarnClient to private shipFiles : List<File> from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_DETACHED : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_DETACHED : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private customName : String from class org.apache.flink.yarn.FlinkYarnClient to private customName : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private yarnApplication : YarnClientApplication from class org.apache.flink.yarn.FlinkYarnClient to private yarnApplication : YarnClientApplication from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public FLINK_JAR_PATH : String from class org.apache.flink.yarn.FlinkYarnClient to public FLINK_JAR_PATH : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private taskManagerMemoryMb : int from class org.apache.flink.yarn.FlinkYarnClient to private taskManagerMemoryMb : int from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private jobManagerMemoryMb : int from class org.apache.flink.yarn.FlinkYarnClient to private jobManagerMemoryMb : int from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private MIN_JM_MEMORY : int from class org.apache.flink.yarn.FlinkYarnClient to private MIN_JM_MEMORY : int from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_TM_COUNT : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_TM_COUNT : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_DYNAMIC_PROPERTIES : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_DYNAMIC_PROPERTIES : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private MIN_TM_MEMORY : int from class org.apache.flink.yarn.FlinkYarnClient to private MIN_TM_MEMORY : int from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private streamingMode : boolean from class org.apache.flink.yarn.FlinkYarnClient to private streamingMode : boolean from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private configurationDirectory : String from class org.apache.flink.yarn.FlinkYarnClient to private configurationDirectory : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private conf : Configuration from class org.apache.flink.yarn.FlinkYarnClient to private conf : Configuration from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_STREAMING_MODE : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_STREAMING_MODE : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute private flinkConfigurationPath : Path from class org.apache.flink.yarn.FlinkYarnClient to private flinkConfigurationPath : Path from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_CLIENT_SHIP_FILES : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_CLIENT_SHIP_FILES : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Pull Up Attribute public ENV_CLIENT_HOME_DIR : String from class org.apache.flink.yarn.FlinkYarnClient to public ENV_CLIENT_HOME_DIR : String from class org.apache.flink.yarn.FlinkYarnClientBase	From	To
Change Return Type	1
Change Return Type LeaderElectionService to Option<LeaderElectionService> in method public createLeaderElectionService() : Option<LeaderElectionService> in class org.apache.flink.runtime.leaderelection.LeaderElectionRetrievalTestingCluster	From	To
Move Class	2
Move Class org.apache.flink.yarn.FlinkYarnClient.ClusterResourceDescription moved to org.apache.flink.yarn.FlinkYarnClientBase.ClusterResourceDescription	From	To
Move Class org.apache.flink.yarn.appMaster.YarnTaskManagerRunner moved to org.apache.flink.yarn.YarnTaskManagerRunner	From	To
Extract Superclass	1
Extract Superclass org.apache.flink.yarn.FlinkYarnClientBase from classes [org.apache.flink.yarn.FlinkYarnClient]	From	To
Change Variable Type	1
Change Variable Type msg : Messages.YarnMessage to msg : YarnMessages.YarnMessage in method public getNewMessages() : List<String> in class org.apache.flink.yarn.FlinkYarnCluster	From	To
Extract Method	1
Extract Method public runYarnTaskManager(args String[], taskManager Class<T>) : void extracted from public main(args String[]) : void in class org.apache.flink.yarn.YarnTaskManagerRunner	From	To

fa2bb8f119f747a24bb013a4387ded5c51348ee7

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: