Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

(trivial) removes some hardcoded fate values #5243

Merged
merged 2 commits into from
Jan 13, 2025
+18 −10
Merged

(trivial) removes some hardcoded fate values #5243

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
3c660e2
Removes some hardcoded values
kevinrr888 Jan 10, 2025
d4f4643
cleanup
kevinrr888 Jan 10, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 12 additions & 4 deletions core/src/main/java/org/apache/accumulo/core/fate/Fate.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -79,6 +79,9 @@ public class Fate<T> {
private final ExecutorService deadResCleanerExecutor;

private static final EnumSet<TStatus> FINISHED_STATES = EnumSet.of(FAILED, SUCCESSFUL, UNKNOWN);
public static final Duration INITIAL_DELAY = Duration.ofSeconds(3);
private static final Duration DEAD_RES_CLEANUP_DELAY = Duration.ofMinutes(3);
private static final Duration POOL_WATCHER_DELAY = Duration.ofSeconds(30);

private final AtomicBoolean keepRunning = new AtomicBoolean(true);
private final TransferQueue<FateId> workQueue;
Expand Down Expand Up @@ -457,7 +460,7 @@ public Fate(T environment, FateStore<T> store, boolean runDeadResCleaner,
idleCountHistory.add(workQueue.getWaitingConsumerCount());
}
}
}, 3, 30, SECONDS));
}, INITIAL_DELAY.toSeconds(), getPoolWatcherDelay().toSeconds(), SECONDS));
this.transactionExecutor = pool;

ScheduledExecutorService deadResCleanerExecutor = null;
Expand All @@ -466,8 +469,9 @@ public Fate(T environment, FateStore<T> store, boolean runDeadResCleaner,
// reservations held by dead processes, if they exist.
deadResCleanerExecutor = ThreadPools.getServerThreadPools().createScheduledExecutorService(1,
store.type() + "-dead-reservation-cleaner-pool");
ScheduledFuture<?> deadReservationCleaner = deadResCleanerExecutor.scheduleWithFixedDelay(
new DeadReservationCleaner(), 3, getDeadResCleanupDelay().toSeconds(), SECONDS);
ScheduledFuture<?> deadReservationCleaner =
deadResCleanerExecutor.scheduleWithFixedDelay(new DeadReservationCleaner(),
INITIAL_DELAY.toSeconds(), getDeadResCleanupDelay().toSeconds(), SECONDS);
ThreadPools.watchCriticalScheduledTask(deadReservationCleaner);
}
this.deadResCleanerExecutor = deadResCleanerExecutor;
Expand All @@ -477,7 +481,11 @@ public Fate(T environment, FateStore<T> store, boolean runDeadResCleaner,
}

public Duration getDeadResCleanupDelay() {
return Duration.ofMinutes(3);
return DEAD_RES_CLEANUP_DELAY;
}

public Duration getPoolWatcherDelay() {
return POOL_WATCHER_DELAY;
}

// get a transaction id back to the requester before doing any work
Expand Down
12 changes: 6 additions & 6 deletions test/src/main/java/org/apache/accumulo/test/fate/FateIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -238,7 +238,7 @@ protected void testTransactionStatus(FateStore<TestEnv> store, ServerContext sct
try {

// Wait for the transaction runner to be scheduled.
Thread.sleep(3000);
Thread.sleep(Fate.INITIAL_DELAY.toMillis() * 2);

callStarted = new CountDownLatch(1);
finishCall = new CountDownLatch(1);
Expand Down Expand Up @@ -295,7 +295,7 @@ protected void testCancelWhileNew(FateStore<TestEnv> store, ServerContext sctx)
try {

// Wait for the transaction runner to be scheduled.
Thread.sleep(3000);
Thread.sleep(Fate.INITIAL_DELAY.toMillis() * 2);

callStarted = new CountDownLatch(1);
finishCall = new CountDownLatch(1);
Expand Down Expand Up @@ -330,7 +330,7 @@ protected void testCancelWhileSubmittedAndRunning(FateStore<TestEnv> store, Serv
try {

// Wait for the transaction runner to be scheduled.
Thread.sleep(3000);
Thread.sleep(Fate.INITIAL_DELAY.toMillis() * 2);

callStarted = new CountDownLatch(1);
finishCall = new CountDownLatch(1);
Expand Down Expand Up @@ -365,7 +365,7 @@ protected void testCancelWhileInCall(FateStore<TestEnv> store, ServerContext sct
try {

// Wait for the transaction runner to be scheduled.
Thread.sleep(3000);
Thread.sleep(Fate.INITIAL_DELAY.toMillis() * 2);

callStarted = new CountDownLatch(1);
finishCall = new CountDownLatch(1);
Expand Down Expand Up @@ -402,7 +402,7 @@ protected void testDeferredOverflow(FateStore<TestEnv> store, ServerContext sctx
try {

// Wait for the transaction runner to be scheduled.
Thread.sleep(3000);
Thread.sleep(Fate.INITIAL_DELAY.toMillis() * 2);

DeferredTestRepo.executedCalls.set(0);
// Initialize the repo to have a delay of 30 seconds
Expand Down Expand Up @@ -479,7 +479,7 @@ protected void testRepoFails(FateStore<TestEnv> store, ServerContext sctx) throw
try {

// Wait for the transaction runner to be scheduled.
Thread.sleep(3000);
Thread.sleep(Fate.INITIAL_DELAY.toMillis() * 2);

List<String> expectedUndoOrder = List.of("OP3", "OP2", "OP1");
/*
Expand Down
Loading