-
- Downloads
[SPARK-5006][Deploy]spark.port.maxRetries doesn't work
https://issues.apache.org/jira/browse/SPARK-5006 I think the issue is produced in https://github.com/apache/spark/pull/1777. Not digging mesos's backend yet. Maybe should add same logic either. Author: WangTaoTheTonic <barneystinson@aliyun.com> Author: WangTao <barneystinson@aliyun.com> Closes #3841 from WangTaoTheTonic/SPARK-5006 and squashes the following commits: 8cdf96d [WangTao] indent thing 2d86d65 [WangTaoTheTonic] fix line length 7cdfd98 [WangTaoTheTonic] fit for new HttpServer constructor 61a370d [WangTaoTheTonic] some minor fixes bc6e1ec [WangTaoTheTonic] rebase 67bcb46 [WangTaoTheTonic] put conf at 3rd position, modify suite class, add comments f450cd1 [WangTaoTheTonic] startServiceOnPort will use a SparkConf arg 29b751b [WangTaoTheTonic] rebase as ExecutorRunnableUtil changed to ExecutorRunnable 396c226 [WangTaoTheTonic] make the grammar more like scala 191face [WangTaoTheTonic] invalid value name 62ec336 [WangTaoTheTonic] spark.port.maxRetries doesn't work
Showing
- core/src/main/scala/org/apache/spark/HttpFileServer.scala 2 additions, 1 deletioncore/src/main/scala/org/apache/spark/HttpFileServer.scala
- core/src/main/scala/org/apache/spark/HttpServer.scala 2 additions, 1 deletioncore/src/main/scala/org/apache/spark/HttpServer.scala
- core/src/main/scala/org/apache/spark/SparkConf.scala 4 additions, 2 deletionscore/src/main/scala/org/apache/spark/SparkConf.scala
- core/src/main/scala/org/apache/spark/SparkEnv.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala 2 additions, 1 deletion...main/scala/org/apache/spark/broadcast/HttpBroadcast.scala
- core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala 1 addition, 1 deletion...cala/org/apache/spark/network/nio/ConnectionManager.scala
- core/src/main/scala/org/apache/spark/ui/JettyUtils.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/ui/JettyUtils.scala
- core/src/main/scala/org/apache/spark/util/AkkaUtils.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/util/AkkaUtils.scala
- core/src/main/scala/org/apache/spark/util/Utils.scala 11 additions, 12 deletionscore/src/main/scala/org/apache/spark/util/Utils.scala
- external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala 1 addition, 1 deletion...a/org/apache/spark/streaming/flume/FlumeStreamSuite.scala
- external/mqtt/src/test/scala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala 2 additions, 1 deletion...ala/org/apache/spark/streaming/mqtt/MQTTStreamSuite.scala
- repl/scala-2.10/src/main/scala/org/apache/spark/repl/SparkIMain.scala 1 addition, 1 deletion....10/src/main/scala/org/apache/spark/repl/SparkIMain.scala
- repl/scala-2.11/src/main/scala/org/apache/spark/repl/Main.scala 1 addition, 1 deletion...cala-2.11/src/main/scala/org/apache/spark/repl/Main.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala 3 additions, 6 deletions...scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala
Loading
Please register or sign in to comment