commitFuture = executor.submit(new CommitCoordinationTask<>(transaction, cohorts, commitStatsTracker,
futureValueSupplier));
} catch (RejectedExecutionException e) {
commitFuture = executor.submit(new CommitCoordinationTask<>(transaction, cohorts, commitStatsTracker,
futureValueSupplier));
} catch (RejectedExecutionException e) {