diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplicationRecompareRunnable.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplicationRecompareRunnable.java index 47f5e606b846..713685b5f4d1 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplicationRecompareRunnable.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplicationRecompareRunnable.java @@ -75,7 +75,7 @@ public void run() { get.setCacheBlocks(tableScan.getCacheBlocks()); get.setFilter(tableScan.getFilter()); - int sleepMs = sleepMsBeforeReCompare; + long sleepMs = sleepMsBeforeReCompare; int tries = 0; while (++tries <= reCompareTries) { @@ -109,7 +109,7 @@ public void run() { } } - sleepMs = sleepMs * (2 ^ reCompareBackoffExponent); + sleepMs = (long) (sleepMs * Math.pow(2, reCompareBackoffExponent)); } LOG.error("{}, rowkey={}{}{}", originalCounter, delimiter, Bytes.toStringBinary(row),