flink d18f5809808221f6bd7c045aa78dfe01dab2afdf

d18f5809808221f6bd7c045aa78dfe01dab2afdf

Files Diff

Added: 4
Removed: 0
Renamed: 0
Modified: 19

Link to commit

com.github.scopt:scopt_2.10:3.2.0
org.clapper:grizzled-slf4j_2.10:1.0.2
org.apache.avro:avro:1.7.6
io.netty:netty-all:4.0.31.Final
org.joda:joda-convert:1.7
com.typesafe.akka:akka-remote_2.10:2.3.7
org.scala-lang:scala-compiler:2.10.4
org.scalatest:scalatest_2.10:2.2.2
commons-collections:commons-collections:3.2.1
com.typesafe.akka:akka-camel_2.10:2.3.7
org.javassist:javassist:3.18.1-GA
joda-time:joda-time:2.5
com.typesafe.akka:akka-slf4j_2.10:2.3.7
stax:stax-api:1.0.1
org.scala-lang:scala-library:2.10.4
org.apache.commons:commons-math3:3.5
org.apache.avro:avro-ipc:1.7.6
com.typesafe.akka:akka-testkit_2.10:2.3.7
org.scala-lang:scala-reflect:2.10.4
com.typesafe.akka:akka-actor_2.10:2.3.7
commons-io:commons-io:2.4
org.apache.zookeeper:zookeeper:3.4.6
com.esotericsoftware.kryo:kryo:2.24.0
commons-cli:commons-cli:1.2

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	1
	Change Parameter Type jobManagerGateway : ActorGateway to leaderRetrievalService : LeaderRetrievalService in method public submitJobAndWait(actorSystem ActorSystem, leaderRetrievalService LeaderRetrievalService, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.JobClient	From	To
	Replace Variable With Attribute	1
	Replace Variable With Attribute leaderRetrievalService : LeaderRetrievalService to timeout : FiniteDuration in method public Client(config Configuration, maxSlots int) in class org.apache.flink.client.program.Client	From	To
	Change Variable Type	1
	Change Variable Type leaderRetrievalService : LeaderRetrievalService to timeout : FiniteDuration in method public Client(config Configuration, maxSlots int) in class org.apache.flink.client.program.Client	From	To
	Change Attribute Type	2
	Change Attribute Type leaderElectionServices : TestingLeaderElectionService[] to leaderElectionServices : List<TestingLeaderElectionService> in class org.apache.flink.runtime.leaderelection.LeaderElectionRetrievalTestingCluster	From	To
	Change Attribute Type leaderRetrievalServices : TestingLeaderRetrievalService[] to leaderRetrievalServices : List<TestingLeaderRetrievalService> in class org.apache.flink.runtime.leaderelection.LeaderElectionRetrievalTestingCluster	From	To
	Extract Method	4
	Extract Method private disconnectFromJobManager() : void extracted from protected handleMessage(message Object) : void in class org.apache.flink.runtime.client.JobClientActor	From	To
	Extract Method private tryToSubmitJob(jobGraph JobGraph) : void extracted from protected handleMessage(message Object) : void in class org.apache.flink.runtime.client.JobClientActor	From	To
	Extract Method private terminate() : void extracted from protected handleMessage(message Object) : void in class org.apache.flink.runtime.client.JobClientActor	From	To
	Extract Method private connectToJobManager(jobManager ActorRef) : void extracted from protected handleMessage(message Object) : void in class org.apache.flink.runtime.client.JobClientActor	From	To
	Extract And Move Method	1
	Extract And Move Method public createJobClientActorProps(leaderRetrievalService LeaderRetrievalService, timeout FiniteDuration, sysoutUpdates boolean) : Props extracted from public submitJobAndWait(actorSystem ActorSystem, jobManagerGateway ActorGateway, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.JobClient & moved to class org.apache.flink.runtime.client.JobClientActor	From	To
	Rename Parameter	1
	Rename Parameter jobManagerGateway : ActorGateway to leaderRetrievalService : LeaderRetrievalService in method public submitJobAndWait(actorSystem ActorSystem, leaderRetrievalService LeaderRetrievalService, jobGraph JobGraph, timeout FiniteDuration, sysoutLogUpdates boolean, classLoader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.JobClient	From	To