From e3a9da0e5387055e6bf54283ce9be4777ae2eff0 Mon Sep 17 00:00:00 2001 From: "cactuslrd.lird" Date: Tue, 6 Jun 2017 12:23:25 +0800 Subject: [PATCH] [FLINK-6852] Fix misuse of GCD --- .../flink/table/runtime/aggregate/AggregateUtil.scala | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala index ccfab00232746..04c5070c6d20e 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala @@ -1501,13 +1501,7 @@ object AggregateUtil { case _ => throw new IllegalArgumentException() } - private[flink] def determineLargestTumblingSize(size: Long, slide: Long): Long = { - if (slide > size) { - gcd(slide, size) - } else { - gcd(size, slide) - } - } + private[flink] def determineLargestTumblingSize(size: Long, slide: Long) = gcd(size, slide) private def gcd(a: Long, b: Long): Long = { if (b == 0) a else gcd(b, a % b)