storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/3] storm git commit: STORM-670: restore java 1.6 compatibility
Date Wed, 11 Mar 2015 21:35:36 GMT
Repository: storm
Updated Branches:
  refs/heads/master 43fe5135a -> a05ba34c8


STORM-670: restore java 1.6 compatibility


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d9568f99
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d9568f99
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d9568f99

Branch: refs/heads/master
Commit: d9568f99841e8449f41353e409eac73aeb3b6dc7
Parents: 8036109
Author: P. Taylor Goetz <ptgoetz@gmail.com>
Authored: Thu Feb 12 12:15:04 2015 -0500
Committer: P. Taylor Goetz <ptgoetz@gmail.com>
Committed: Thu Feb 12 12:20:30 2015 -0500

----------------------------------------------------------------------
 .../src/jvm/storm/kafka/ExponentialBackoffMsgRetryManager.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/d9568f99/external/storm-kafka/src/jvm/storm/kafka/ExponentialBackoffMsgRetryManager.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/ExponentialBackoffMsgRetryManager.java
b/external/storm-kafka/src/jvm/storm/kafka/ExponentialBackoffMsgRetryManager.java
index 9b2c904..8c0bbe1 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/ExponentialBackoffMsgRetryManager.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/ExponentialBackoffMsgRetryManager.java
@@ -156,7 +156,7 @@ public class ExponentialBackoffMsgRetryManager implements FailedMsgRetryManager
 
         @Override
         public int compare(MessageRetryRecord record1, MessageRetryRecord record2) {
-            return Long.compare(record1.retryTimeUTC, record2.retryTimeUTC);
+            return Long.valueOf(record1.retryTimeUTC).compareTo(Long.valueOf(record2.retryTimeUTC));
         }
 
         @Override


Mime
View raw message