Repository: incubator-gobblin Updated Branches: refs/heads/master 4997fa9bb -> 4f5223028
[GOBBLIN-411] Fix bug in FIFO based pull file loader Closes #2288 from arjun4084346/sortFix Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/4f522302 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/4f522302 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/4f522302 Branch: refs/heads/master Commit: 4f5223028ebf3f79349720cca2f80f9dabf8f604 Parents: 4997fa9 Author: Arjun <ab...@linkedin.com> Authored: Thu Feb 15 20:52:17 2018 -0800 Committer: Hung Tran <hut...@linkedin.com> Committed: Thu Feb 15 20:52:17 2018 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/gobblin/util/PullFileLoader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/4f522302/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java index 210615c..9270491 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java @@ -168,7 +168,7 @@ public class PullFileLoader { private List<Config> getSortedConfigs(List<ConfigWithTimeStamp> configsWithTimeStamps) { List<Config> sortedConfigs = Lists.newArrayList(); - Collections.sort(configsWithTimeStamps, (config1, config2) -> (config1.timeStamp > config2.timeStamp) ? 1 : -1); + Collections.sort(configsWithTimeStamps, Comparator.comparingLong(o -> o.timeStamp)); for (ConfigWithTimeStamp configWithTimeStamp : configsWithTimeStamps) { sortedConfigs.add(configWithTimeStamp.config); }