diff options
| author | Yijie Shen <henry.yijieshen@gmail.com> | 2014-07-03 13:22:13 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2014-07-03 13:22:13 -0700 |
| commit | a9b52e5623f7fc77fca96b095f9eeaef76e35d54 (patch) | |
| tree | b4d80da53359488ae25e6d09abb8be867d773779 | |
| parent | 2b36344f588d4e7357ce9921dc656e2389ba1dea (diff) | |
| download | spark-a9b52e5623f7fc77fca96b095f9eeaef76e35d54.tar.gz spark-a9b52e5623f7fc77fca96b095f9eeaef76e35d54.tar.bz2 spark-a9b52e5623f7fc77fca96b095f9eeaef76e35d54.zip | |
[SPARK-2342] Evaluation helper's output type doesn't conform to input ty...
The function cast doesn't conform to the intention of "Those expressions are supposed to be in the same data type, and also the return type." comment
Author: Yijie Shen <henry.yijieshen@gmail.com>
Closes #1283 from yijieshen/master and squashes the following commits:
c7aaa4b [Yijie Shen] [SPARK-2342] Evaluation helper's output type doesn't conform to input type
| -rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala index 0411ce3aef..ba62dabe3d 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Expression.scala @@ -111,7 +111,7 @@ abstract class Expression extends TreeNode[Expression] { } else { e1.dataType match { case n: NumericType => - f.asInstanceOf[(Numeric[n.JvmType], n.JvmType, n.JvmType) => Int]( + f.asInstanceOf[(Numeric[n.JvmType], n.JvmType, n.JvmType) => n.JvmType]( n.numeric, evalE1.asInstanceOf[n.JvmType], evalE2.asInstanceOf[n.JvmType]) case other => sys.error(s"Type $other does not support numeric operations") } |