SENTRY-1792: Ensure DB to sort delta changes by CHANGE_ID (Vamsee Yarlagadda, Reviewed by: Alex Kolbasov)
Change-Id: I8c8687ba1a892b4d2f860920d8d6198f3aded7d9 Reviewed-on: http://gerrit.sjc.cloudera.com:8080/23563 Tested-by: Jenkins User Reviewed-by: Vamsee Yarlagadda <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/sentry/repo Commit: http://git-wip-us.apache.org/repos/asf/sentry/commit/302d3d28 Tree: http://git-wip-us.apache.org/repos/asf/sentry/tree/302d3d28 Diff: http://git-wip-us.apache.org/repos/asf/sentry/diff/302d3d28 Branch: refs/for/cdh5-1.5.1_ha Commit: 302d3d2856cbf281be8be1b6c4209704be66f901 Parents: de52c7e Author: Vamsee Yarlagadda <[email protected]> Authored: Wed Jun 7 15:16:10 2017 -0700 Committer: Vamsee Yarlagadda <[email protected]> Committed: Thu Jun 8 11:10:03 2017 -0700 ---------------------------------------------------------------------- .../apache/sentry/provider/db/service/persistent/SentryStore.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sentry/blob/302d3d28/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/provider/db/service/persistent/SentryStore.java ---------------------------------------------------------------------- diff --git a/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/provider/db/service/persistent/SentryStore.java b/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/provider/db/service/persistent/SentryStore.java index d77c87a..776e1cd 100644 --- a/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/provider/db/service/persistent/SentryStore.java +++ b/sentry-provider/sentry-provider-db/src/main/java/org/apache/sentry/provider/db/service/persistent/SentryStore.java @@ -3148,6 +3148,7 @@ public class SentryStore { Query query = pm.newQuery(changeCls); query.setFilter("this.changeID >= t"); query.declareParameters("long t"); + query.setOrdering("this.changeID ascending"); return (List<T>) query.execute(changeID); }
