diff --git a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java index 5fb6d863d1..9733256db8 100644 --- a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java +++ b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java @@ -3925,13 +3925,13 @@ protected String isWithinCheckInterval(String expr, long interval) throws MetaEx break; case MYSQL: case POSTGRES: - condition = expr + " => current_timestamp - interval '" + interval + "' second"; + condition = expr + " >= current_timestamp - interval '" + interval + "' second"; break; case SQLSERVER: condition = "DATEDIFF(second, " + expr + ", current_timestamp) <= " + interval; break; case ORACLE: - condition = expr + " => current_timestamp - numtodsinterval(" + interval + " , 'second')"; + condition = expr + " >= current_timestamp - numtodsinterval(" + interval + " , 'second')"; break; default: String msg = "Unknown database product: " + dbProduct.toString();