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)