flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject flink git commit: [FLINK-3593][tableAPI] Fix failing DistinctITCase
Date Tue, 08 Mar 2016 19:36:26 GMT
Repository: flink
Updated Branches:
  refs/heads/tableOnCalcite e9b9b6f3a -> e34e43954


[FLINK-3593][tableAPI] Fix failing DistinctITCase


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e34e4395
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e34e4395
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e34e4395

Branch: refs/heads/tableOnCalcite
Commit: e34e439549910761a19676ae6659add5233ddf1a
Parents: e9b9b6f
Author: Fabian Hueske <fhueske@apache.org>
Authored: Tue Mar 8 20:35:54 2016 +0100
Committer: Fabian Hueske <fhueske@apache.org>
Committed: Tue Mar 8 20:35:54 2016 +0100

----------------------------------------------------------------------
 .../apache/flink/api/table/runtime/aggregate/AggregateUtil.scala   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/e34e4395/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
b/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
index 6c1d489..1b876da 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateUtil.scala
@@ -99,7 +99,7 @@ object AggregateUtil {
           "or aggregate functions.")
     }
 
-    val allPartialAggregate = aggregates.map(_.supportPartial).reduce(_ && _)
+    val allPartialAggregate = aggregates.map(_.supportPartial).forall(x => x)
 
     val intermediateRowArity = groupings.length + aggregates.map(_.intermediateDataType.length).sum
 


Mime
View raw message