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.
@@ -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) {
