Skip to content

Commit

Permalink
Resolve comments
Browse files Browse the repository at this point in the history
  • Loading branch information
JkSelf committed Oct 14, 2024
1 parent 4d293dc commit fb7cfa7
Showing 1 changed file with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -155,13 +155,13 @@ void verifyFailures(LibHdfsShim* driver, hdfsFS hdfs) {

checkReadErrorMessages(&readFile, offsetErrorMessage, kOneMB);
HdfsFileSystemTest::miniCluster->stop();
// Sleep for 10 seconds after stopping the miniCluster to ensure consistency
// in connection status.
// This prevents a scenario where the first pread call in the
// checkReadErrorMessages method might succeed, while a subsequent call fails,
// leading to a mismatch in readFailErrorMessage.
sleep(10);
checkReadErrorMessages(&readFile2, readFailErrorMessage, 1);
while (true) {
if (!HdfsFileSystemTest::miniCluster->isRunning()) {
checkReadErrorMessages(&readFile2, readFailErrorMessage, 1);
} else {
continue;
}
}
}

hdfsFS connectHdfsDriver(
Expand Down

0 comments on commit fb7cfa7

Please sign in to comment.