1 files changed, 5 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/TypeInferenceUtils.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/TypeInferenceUtils.java
index 3319104dc..9b0142405 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/TypeInferenceUtils.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/TypeInferenceUtils.java
@@ -593,7 +593,11 @@ public class TypeInferenceUtils {
         case SECOND:
         case MINUTE:
         case HOUR:
-          sqlTypeName = SqlTypeName.TIMESTAMP;
+          if (inputTypeName == SqlTypeName.TIME) {
+            sqlTypeName = SqlTypeName.TIME;
+          } else {
+            sqlTypeName = SqlTypeName.TIMESTAMP;
+          }
           break;
         default:
           sqlTypeName = SqlTypeName.ANY;