Repository: reef Updated Branches: refs/heads/REEF-335 d243aa2a3 -> de1724c81
http://git-wip-us.apache.org/repos/asf/reef/blob/de1724c8/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/driver/service/parameters/HTTPStatusNumberOfRetries.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/driver/service/parameters/HTTPStatusNumberOfRetries.java b/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/driver/service/parameters/HTTPStatusNumberOfRetries.java new file mode 100644 index 0000000..c3d16be --- /dev/null +++ b/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/driver/service/parameters/HTTPStatusNumberOfRetries.java @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.reef.bridge.driver.service.parameters; + +import org.apache.reef.tang.annotations.Name; +import org.apache.reef.tang.annotations.NamedParameter; + +/** + * Number of times the HTTPStatusHandler will advance its alarm. + */ +@NamedParameter(default_value = "10", doc = "Number of times the HTTPStatusHandler will advance its alarm.") +public final class HTTPStatusNumberOfRetries implements Name<Integer> { + + private HTTPStatusNumberOfRetries() { + // Intentionally empty. + } +} http://git-wip-us.apache.org/repos/asf/reef/blob/de1724c8/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/examples/hello/HelloREEF.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/examples/hello/HelloREEF.java b/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/examples/hello/HelloREEF.java index e80cf1e..9b48823 100644 --- a/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/examples/hello/HelloREEF.java +++ b/lang/java/reef-bridge-proto-java/src/main/java/org/apache/reef/bridge/examples/hello/HelloREEF.java @@ -56,8 +56,8 @@ public final class HelloREEF { final ClientProtocol.DriverClientConfiguration.Builder builder = ClientProtocol.DriverClientConfiguration.newBuilder(); builder.setJobid("HelloREEF"); - builder.setLocalRuntime(ClientProtocol.LocalRuntimeParameters.newBuilder() - .setMaxNumberOfEvaluators(1) + builder.setEnableHttpDriver(false); + builder.setAzbatchRuntime(ClientProtocol.AzureBatchRuntimeParameters.newBuilder() .build()); builder.addGlobalLibraries(EnvironmentUtils.getClassLocation(HelloDriver.class)); http://git-wip-us.apache.org/repos/asf/reef/blob/de1724c8/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/parameters/JobSubmissionDirectoryPrefix.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/parameters/JobSubmissionDirectoryPrefix.java b/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/parameters/JobSubmissionDirectoryPrefix.java index 5a52270..a658f7b 100644 --- a/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/parameters/JobSubmissionDirectoryPrefix.java +++ b/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/parameters/JobSubmissionDirectoryPrefix.java @@ -26,4 +26,9 @@ import org.apache.reef.tang.annotations.NamedParameter; */ @NamedParameter(doc = "The job submission directory prefix.", default_value = "/tmp") public final class JobSubmissionDirectoryPrefix implements Name<String> { + + private JobSubmissionDirectoryPrefix() { + } + + public static final String DEFAULT_VALUE = "/tmp"; } http://git-wip-us.apache.org/repos/asf/reef/blob/de1724c8/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index bd35fbd..1b14694 100644 --- a/pom.xml +++ b/pom.xml @@ -50,7 +50,7 @@ under the License. <reef.log.dir>${project.build.directory}/log</reef.log.dir> <bundle.snappy>false</bundle.snappy> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> - <hadoop.version>2.7.0</hadoop.version> + <hadoop.version>2.7.5</hadoop.version> <spark.version>2.1.0</spark.version> <avro.version>1.8.1</avro.version> <parquet.version>1.9.0</parquet.version>
