Fix checkpoints in assertion

The checkpoints in the assertion message that the follower checkpoint is
less than the leader checkpoint are backwards. This commit fixes this
message.
This commit is contained in:
Jason Tedor 2018-01-15 11:50:12 -05:00
parent 18788531c8
commit bad5135d35
1 changed files with 2 additions and 2 deletions

View File

@ -102,8 +102,8 @@ public class ShardFollowTasksExecutor extends PersistentTasksExecutor<ShardFollo
if (leaderGlobalCheckPoint == followGlobalCheckPoint) {
retry(task, params, followGlobalCheckPoint);
} else {
assert followGlobalCheckPoint < leaderGlobalCheckPoint : "followGlobalCheckPoint [" + leaderGlobalCheckPoint +
"] is not below leaderGlobalCheckPoint [" + followGlobalCheckPoint + "]";
assert followGlobalCheckPoint < leaderGlobalCheckPoint : "followGlobalCheckPoint [" + followGlobalCheckPoint +
"] is not below leaderGlobalCheckPoint [" + leaderGlobalCheckPoint + "]";
Executor ccrExecutor = threadPool.executor(Ccr.CCR_THREAD_POOL_NAME);
Consumer<Exception> handler = e -> {
if (e == null) {