@@ -1268,6 +1268,14 @@ private void writeCompactionWalRecord(Collection<HStoreFile> filesCompacted,
1268
1268
allowedOnPath = ".*/(HStore|TestHStore).java" )
1269
1269
void replaceStoreFiles (Collection <HStoreFile > compactedFiles , Collection <HStoreFile > result ,
1270
1270
boolean writeCompactionMarker ) throws IOException {
1271
+ // These may be null when the RS is shutting down. The space quota Chores will fix the Region
1272
+ // sizes later so it's not super-critical if we miss these.
1273
+ RegionServerServices rsServices = region .getRegionServerServices ();
1274
+ if (rsServices != null && rsServices .getRegionServerSpaceQuotaManager () != null ) {
1275
+ updateSpaceQuotaAfterFileReplacement (
1276
+ rsServices .getRegionServerSpaceQuotaManager ().getRegionSizeStore (), getRegionInfo (),
1277
+ compactedFiles , result );
1278
+ }
1271
1279
storeEngine .replaceStoreFiles (compactedFiles , result , () -> {
1272
1280
if (writeCompactionMarker ) {
1273
1281
writeCompactionWalRecord (compactedFiles , result );
@@ -1277,14 +1285,6 @@ void replaceStoreFiles(Collection<HStoreFile> compactedFiles, Collection<HStoreF
1277
1285
filesCompacting .removeAll (compactedFiles );
1278
1286
}
1279
1287
});
1280
- // These may be null when the RS is shutting down. The space quota Chores will fix the Region
1281
- // sizes later so it's not super-critical if we miss these.
1282
- RegionServerServices rsServices = region .getRegionServerServices ();
1283
- if (rsServices != null && rsServices .getRegionServerSpaceQuotaManager () != null ) {
1284
- updateSpaceQuotaAfterFileReplacement (
1285
- rsServices .getRegionServerSpaceQuotaManager ().getRegionSizeStore (), getRegionInfo (),
1286
- compactedFiles , result );
1287
- }
1288
1288
}
1289
1289
1290
1290
/**
0 commit comments