diff options
| author | Neelesh Srinivas Salian <nsalian@cloudera.com> | 2015-08-14 20:03:50 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-08-14 20:03:50 +0100 |
| commit | 57c2d08800a506614b461b5a505a1dd1a28a8908 (patch) | |
| tree | bbb52ef7d85162aa0bb236318f259f7d38da12dc /core | |
| parent | 34d610be854d2a975d9c1e232d87433b85add6fd (diff) | |
| download | spark-57c2d08800a506614b461b5a505a1dd1a28a8908.tar.gz spark-57c2d08800a506614b461b5a505a1dd1a28a8908.tar.bz2 spark-57c2d08800a506614b461b5a505a1dd1a28a8908.zip | |
[SPARK-9923] [CORE] ShuffleMapStage.numAvailableOutputs should be an Int instead of Long
Modified type of ShuffleMapStage.numAvailableOutputs from Long to Int
Author: Neelesh Srinivas Salian <nsalian@cloudera.com>
Closes #8183 from nssalian/SPARK-9923.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/ShuffleMapStage.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapStage.scala b/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapStage.scala index 66c75f325f..48d8d8e9c4 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapStage.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/ShuffleMapStage.scala @@ -37,7 +37,7 @@ private[spark] class ShuffleMapStage( override def toString: String = "ShuffleMapStage " + id - var numAvailableOutputs: Long = 0 + var numAvailableOutputs: Int = 0 def isAvailable: Boolean = numAvailableOutputs == numPartitions |