aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHarvey Feng <harvey@databricks.com>2013-10-15 18:05:34 -0700
committerHarvey Feng <harvey@databricks.com>2013-10-15 18:06:37 -0700
commit5b8083fee5dec145f61684070a1977c9beb98cb2 (patch)
tree04b51f31de41ff3410e8626b64385c17ea42a33c
parent3249e0e90dd9a7b422f561c42407b6a2b3feab17 (diff)
downloadspark-5b8083fee5dec145f61684070a1977c9beb98cb2.tar.gz
spark-5b8083fee5dec145f61684070a1977c9beb98cb2.tar.bz2
spark-5b8083fee5dec145f61684070a1977c9beb98cb2.zip
Make TaskContext's stageId publicly accessible.
-rw-r--r--core/src/main/scala/org/apache/spark/TaskContext.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/TaskContext.scala b/core/src/main/scala/org/apache/spark/TaskContext.scala
index 51584d686d..cae983ed4c 100644
--- a/core/src/main/scala/org/apache/spark/TaskContext.scala
+++ b/core/src/main/scala/org/apache/spark/TaskContext.scala
@@ -22,7 +22,7 @@ import scala.collection.mutable.ArrayBuffer
import org.apache.spark.executor.TaskMetrics
class TaskContext(
- private[spark] val stageId: Int,
+ val stageId: Int,
val partitionId: Int,
val attemptId: Long,
val runningLocally: Boolean = false,