Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
2.0.0
-
None
-
Reviewed
Description
private void initInmemoryFlushSize(Configuration conf) { long memstoreFlushSize = getRegionServices().getMemstoreFlushSize(); int numStores = getRegionServices().getNumStores(); if (numStores <= 1) { // Family number might also be zero in some of our unit test case numStores = 1; } inmemoryFlushSize = memstoreFlushSize / numStores;
We initialize each store in parallel, so the return value from getNumStores() may be different for each CompactingMemStore.