diff --git a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java index 5e3e31c1bc55..12240a3ac654 100644 --- a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java +++ b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java @@ -258,6 +258,7 @@ public CompactionInfo findNextToCompact(FindNextCompactRequest rqst) throws Meta sb.append("\"CQ_POOL_NAME\" IS NULL OR \"CQ_ENQUEUE_TIME\" < (") .append(getEpochFn(dbProduct)).append(" - ").append(poolTimeout).append(")"); } + sb.append(" ORDER BY \"CQ_ID\" ASC"); String query = sb.toString(); stmt = dbConn.prepareStatement(query); if (hasPoolName) {