diff options
| author | Wenchen Fan <cloud0fan@outlook.com> | 2015-07-18 11:58:53 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-07-18 11:58:53 -0700 |
| commit | 86c50bf72c41d95107a55c16a6853dcda7f3e143 (patch) | |
| tree | 6adeb1790c7683197f6812d64dae859e593911fa /core | |
| parent | 692378c01d949dfe2b2a884add153cd5f8054b5a (diff) | |
| download | spark-86c50bf72c41d95107a55c16a6853dcda7f3e143.tar.gz spark-86c50bf72c41d95107a55c16a6853dcda7f3e143.tar.bz2 spark-86c50bf72c41d95107a55c16a6853dcda7f3e143.zip | |
[SPARK-9171][SQL] add and improve tests for nondeterministic expressions
Author: Wenchen Fan <cloud0fan@outlook.com>
Closes #7496 from cloud-fan/tests and squashes the following commits:
0958f90 [Wenchen Fan] improve test for nondeterministic expressions
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/TaskContext.scala | 2 |
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 345bb500a7..e93eb93124 100644 --- a/core/src/main/scala/org/apache/spark/TaskContext.scala +++ b/core/src/main/scala/org/apache/spark/TaskContext.scala @@ -38,7 +38,7 @@ object TaskContext { */ def getPartitionId(): Int = { val tc = taskContext.get() - if (tc == null) { + if (tc eq null) { 0 } else { tc.partitionId() |