25a622fd9c9255bd1a5b4b6ff7891730dce34ac1
Files Diff
- Added: 12
- Removed: 0
- Renamed: 0
- Modified: 43
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Attribute | 1 | ||
| Extract Attribute private zkTimeout : String in class org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute tmp : TemporaryFolder to temp : TemporaryFolder in class org.apache.flink.yarn.YARNHighAvailabilityITCase | From | To | |
| Rename Attribute ENV_CLIENT_USERNAME : String to ENV_HADOOP_USER_NAME : String in class org.apache.flink.yarn.YarnConfigKeys | From | To | |
| Extract Method | 4 | ||
| Extract Method private start(conf Configuration, principal String, keytab String) : void extracted from public startYARNWithConfig(conf Configuration) : void in class org.apache.flink.yarn.YarnTestBase | From | To | |
| Extract Method protected shutdownClusters() : void extracted from public shutDownServices() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTestBase | From | To | |
| Extract Method protected startClusters(secureMode boolean) : void extracted from public prepare() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTestBase | From | To | |
| Extract Method protected getFlinkConfiguration() : Configuration extracted from public prepare() : void in class org.apache.flink.streaming.connectors.kafka.KafkaTestBase | From | To |