fix

prabeesh · Jul 27, 2015 · 522e91a · 522e91a
1 parent e8a639a
commit 522e91a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/DateTimeUtils.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/DateTimeUtils.scala
@@ -671,7 +671,7 @@ object DateTimeUtils {
     val timeInDay1 = time1 - daysToMillis(date1) * 1000L
     val timeInDay2 = time2 - daysToMillis(date2) * 1000L
     if (dayInMonth1 == dayInMonth2 || (lastDayMonth1 == dayInMonth1 &&
-      lastDayMonth2 == dayInMonth2) || dayInMonth2 >= lastDayMonth1) {
+      lastDayMonth2 == dayInMonth2)) {
       (months1 - months2).toDouble
     } else {
       val timesBetween = (timeInDay1 - timeInDay2).toDouble / (MILLIS_PER_DAY * 1000)