Skip to content

Commit

Permalink
HADOOP-19093. ILoadTestRenameRecovery
Browse files Browse the repository at this point in the history
Don't seem able to generate enough load to force the problem

Change-Id: I35af099611dcc0dc90719d0abc951935c9f3d930
  • Loading branch information
steveloughran committed Feb 27, 2024
1 parent b6bb383 commit e250fff
Showing 1 changed file with 2 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -68,12 +68,12 @@ public class ILoadTestRenameRecovery extends AbstractAbfsIntegrationTest {
/**
* Number of threads to use.
*/
private final int threadCount = 5;
private final int threadCount = 100;

/**
* Number of renames to attempt per thread: {@value}.
*/
public static final int RENAMES = 10;
public static final int RENAMES = 100;

/**
* Thread number; used for paths and messages.
Expand Down Expand Up @@ -116,11 +116,6 @@ public class ILoadTestRenameRecovery extends AbstractAbfsIntegrationTest {
*/
private final AtomicLong rateLimitingTime = new AtomicLong(0);

/**
* Object to block all threads on.
*/
private static final Object begin = new Object();

public ILoadTestRenameRecovery() throws Exception {
}

Expand Down Expand Up @@ -175,11 +170,6 @@ public void testResilientRename() throws Throwable {
renameWorker(id, fs, source, dest)));
}

// start the work
synchronized (begin) {
begin.notifyAll();
}

// now wait for the futures
awaitAllFutures(futures, SLEEP_INTERVAL);
LOG.info("Rate limiting time: {}", Duration.ofMillis(rateLimitingTime.get()));
Expand Down Expand Up @@ -208,9 +198,6 @@ private void renameWorker(
int recoveries = 0;
Duration totalWaitTime = Duration.ZERO;
try {
synchronized (begin) {
begin.wait();
}
LOG.info("Starting thread {}", id);

int limit = RENAMES;
Expand Down

0 comments on commit e250fff

Please sign in to comment.