diff --git a/.gitignore b/.gitignore index b519d406e859e..0afd000c4b30a 100644 --- a/.gitignore +++ b/.gitignore @@ -18,3 +18,4 @@ tmp .DS_Store _site docs/api +atlassian-ide-plugin.xml diff --git a/.travis.yml b/.travis.yml index 7c745e7c37c19..af2f082093916 100644 --- a/.travis.yml +++ b/.travis.yml @@ -1,7 +1,15 @@ # s3 deployment based on http://about.travis-ci.org/blog/2012-12-18-travis-artifacts/ -language: java +# send to container based infrastructure: http://docs.travis-ci.com/user/workers/container-based-infrastructure/ +sudo: false + +cache: + directories: + - $HOME/.m2 + +install: true +language: java #See https://issues.apache.org/jira/browse/FLINK-1072 matrix: @@ -44,12 +52,9 @@ before_script: - "gem install --no-document --version 0.8.9 faraday " - "gem install --no-document travis-artifacts & " - -install: true - # we have to manually set the forkCount because maven thinks that the travis # machine has 32 cores -script: "mvn -Dflink.forkCount=4 -B $PROFILE clean install verify" +script: "mvn -Dflink.forkCount=2 -B $PROFILE clean install verify" # deploy if the first job is successful; should be replaced by an after_all_success if travis finally supports it after_success: diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala index 32fdb371c15ce..fbf5d837ec993 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala @@ -33,6 +33,7 @@ FlinkMiniCluster(userConfiguration){ import LocalFlinkMiniCluster._ val jobClientActorSystem = AkkaUtils.createActorSystem() + var jobClient: Option[ActorRef] = None override def generateConfiguration(userConfiguration: Configuration): Configuration = { val config = getDefaultConfig @@ -72,13 +73,18 @@ FlinkMiniCluster(userConfiguration){ } def getJobClient(): ActorRef ={ - val config = new Configuration() - - config.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY, HOSTNAME) - config.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, getJobManagerRPCPort) + jobClient match { + case Some(jc) => jc + case None => + val config = new Configuration() + config.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY, HOSTNAME) + config.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, getJobManagerRPCPort) - JobClient.startActorWithConfiguration(config)(jobClientActorSystem) + val jc = JobClient.startActorWithConfiguration(config)(jobClientActorSystem) + jobClient = Some(jc) + jc + } } def getJobClientActorSystem: ActorSystem = jobClientActorSystem diff --git a/pom.xml b/pom.xml index 6a27cf0c98aa2..d5a0c0a948b6e 100644 --- a/pom.xml +++ b/pom.xml @@ -76,7 +76,7 @@ under the License. - 1C + 1.5C true 1.7.7 17.0 @@ -662,6 +662,7 @@ under the License. **/*.iml flink-quickstart/**/testArtifact/goal.txt + atlassian-ide-plugin.xml **/target/** docs/_site/**