Avoided org.apache.spark.sql.AnalysisException: probability must be DoubleType, however it is FloatType; (VectorQueryTest.scala:80)
Project: http://git-wip-us.apache.org/repos/asf/incubator-hivemall/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-hivemall/commit/90461cbf Tree: http://git-wip-us.apache.org/repos/asf/incubator-hivemall/tree/90461cbf Diff: http://git-wip-us.apache.org/repos/asf/incubator-hivemall/diff/90461cbf Branch: refs/heads/v0.5.0 Commit: 90461cbfd2ac95976561a002ae4cbcf34cffed39 Parents: affc6b4 Author: Makoto Yui <[email protected]> Authored: Tue Jan 23 18:36:13 2018 +0900 Committer: Makoto Yui <[email protected]> Committed: Tue Jan 23 18:36:13 2018 +0900 ---------------------------------------------------------------------- .../scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-hivemall/blob/90461cbf/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala ---------------------------------------------------------------------- diff --git a/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala b/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala index 00617b7..4a6b568 100644 --- a/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala +++ b/spark/spark-2.2/src/main/scala/org/apache/spark/sql/hive/HivemallGroupedDataset.scala @@ -127,7 +127,7 @@ final class HivemallGroupedDataset(groupBy: RelationalGroupedDataset) { * @group ensemble */ def max_label(score: String, label: String): DataFrame = { - checkType(score, DoubleType) + //checkType(score, DoubleType) checkType(label, StringType) val udaf = HiveUDAFFunction( "max_label",
