diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java index 7b2e201e5a..2a5b854f78 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java @@ -4270,8 +4270,9 @@ private RexWindowBound getBound(BoundarySpec bs) { if (bs != null) { SqlParserPos pos = new SqlParserPos(1, 1); - SqlNode amt = bs.getAmt() == 0 ? null : SqlLiteral.createExactNumeric( - String.valueOf(bs.getAmt()), new SqlParserPos(2, 2)); + SqlNode amt = bs.getAmt() == 0 || bs.getAmt() == BoundarySpec.UNBOUNDED_AMOUNT + ? null + : SqlLiteral.createExactNumeric(String.valueOf(bs.getAmt()), new SqlParserPos(2, 2)); RexNode amtLiteral = null; SqlCall sc = null;