diff options
| author | Kousuke Saruta <sarutak@oss.nttdata.co.jp> | 2014-11-14 22:36:56 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2014-11-14 22:36:56 -0800 |
| commit | 60969b0336930449a826821a48f83f65337e8856 (patch) | |
| tree | 55f0c1506fbc0ccc80c1bb2ef8d42d84328b563f /core | |
| parent | 861223ee5bea8e434a9ebb0d53f436ce23809f9c (diff) | |
| download | spark-60969b0336930449a826821a48f83f65337e8856.tar.gz spark-60969b0336930449a826821a48f83f65337e8856.tar.bz2 spark-60969b0336930449a826821a48f83f65337e8856.zip | |
[SPARK-4260] Httpbroadcast should set connection timeout.
Httpbroadcast sets read timeout but doesn't set connection timeout.
Author: Kousuke Saruta <sarutak@oss.nttdata.co.jp>
Closes #3122 from sarutak/httpbroadcast-timeout and squashes the following commits:
c7f3a56 [Kousuke Saruta] Added Connection timeout for Http Connection to HttpBroadcast.scala
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala b/core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala index 7dade04273..31f0a462f8 100644 --- a/core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala +++ b/core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala @@ -191,10 +191,12 @@ private[broadcast] object HttpBroadcast extends Logging { logDebug("broadcast security enabled") val newuri = Utils.constructURIForAuthentication(new URI(url), securityManager) uc = newuri.toURL.openConnection() + uc.setConnectTimeout(httpReadTimeout) uc.setAllowUserInteraction(false) } else { logDebug("broadcast not using security") uc = new URL(url).openConnection() + uc.setConnectTimeout(httpReadTimeout) } val in = { |