-
Notifications
You must be signed in to change notification settings - Fork 3.4k
HBASE-29783 Fix flaky TestVerifyBucketCacheFile.testRetrieveFromFile … #7613
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.
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
base: master
Are you sure you want to change the base?
Conversation
|
After investigating, I found that the only problem is a typo... We should use recoveredBucketCache instead of BucketCache here... And also did some simple changes to cleanup the warnings in BucketCache. @wchevreuil PTAL. This is only 100% fail test for now... |
|
🎊 +1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
| * Basic test for check file's integrity before start BucketCache in fileIOEngine | ||
| */ | ||
| @RunWith(Parameterized.class) | ||
| @Category(SmallTests.class) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Almost each test method is waiting for cache initialization with 10 second timeout. Do you think we can still keep it in SmallTest category ?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I guess this is just for increasing stability, since we do not need to start a mini cluster, the test can finish within 30 seconds.
hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
Outdated
Show resolved
Hide resolved
| constructedBlockSizes, writeThreads, writerQLen, testDir + "/bucket.persistence"); | ||
| waitPersistentCacheValidation(conf, bucketCache); | ||
| assertTrue(recoveredBucketCache.waitForCacheInitialization(10000)); | ||
| waitPersistentCacheValidation(conf, recoveredBucketCache); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this the main fix. We were using a bucketCache which is deleted instead of the recoveredBucketCache?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yes, just a typo... We should recoveredBucketCache instead of bucketCache here...
…cket/BucketCache.java Co-authored-by: Aman Poonia <aman.poonia.29@gmail.com>
|
🎊 +1 overall
This message was automatically generated. |
|
💔 -1 overall
This message was automatically generated. |
|
Ping @wchevreuil |
…test