@@ -212,7 +212,7 @@ public int updateAndCheckTablets(Manager manager, FateId fateId)
212
212
tabletsMutator .mutateTablet (tablet .getExtent ()).requireAbsentOperation ()
213
213
.requireSame (tablet , FILES , COMPACTED ).putCompacted (fateId )
214
214
.submit (tabletMetadata -> tabletMetadata .getCompacted ().contains (fateId ),
215
- () -> "no files, attempting to mark as compacted" );
215
+ () -> "no files, attempting to mark as compacted. " + fateId );
216
216
noFiles ++;
217
217
} else if (tablet .getSelectedFiles () == null && tablet .getExternalCompactions ().isEmpty ()) {
218
218
// there are no selected files
@@ -244,7 +244,7 @@ public int updateAndCheckTablets(Manager manager, FateId fateId)
244
244
tabletsMutator .mutateTablet (tablet .getExtent ()).requireAbsentOperation ()
245
245
.requireSame (tablet , FILES , SELECTED , ECOMP , COMPACTED ).putCompacted (fateId )
246
246
.submit (tabletMetadata -> tabletMetadata .getCompacted ().contains (fateId ),
247
- () -> "no files, attempting to mark as compacted" );
247
+ () -> "no files, attempting to mark as compacted. " + fateId );
248
248
249
249
noneSelected ++;
250
250
} else {
@@ -266,7 +266,7 @@ public int updateAndCheckTablets(Manager manager, FateId fateId)
266
266
tabletMetadata -> tabletMetadata .getSelectedFiles () != null
267
267
&& tabletMetadata .getSelectedFiles ().getFateId ().equals (fateId )
268
268
|| tabletMetadata .getCompacted ().contains (fateId ),
269
- () -> "selecting files for compaction" );
269
+ () -> "selecting files for compaction. " + fateId );
270
270
271
271
if (minSelected == null || tablet .getExtent ().compareTo (minSelected ) < 0 ) {
272
272
minSelected = tablet .getExtent ();
@@ -303,7 +303,7 @@ public int updateAndCheckTablets(Manager manager, FateId fateId)
303
303
.requireSame (tablet , ECOMP , USER_COMPACTION_REQUESTED )
304
304
.putUserCompactionRequested (fateId );
305
305
mutator .submit (tm -> tm .getUserCompactionsRequested ().contains (fateId ),
306
- () -> "marking as needing a user requested compaction" );
306
+ () -> "marking as needing a user requested compaction. " + fateId );
307
307
userCompactionRequested ++;
308
308
} else {
309
309
// Marker was already added and we are waiting
@@ -405,7 +405,8 @@ private void cleanupTabletMetadata(FateId fateId, Manager manager) throws Except
405
405
mutator .deleteUserCompactionRequested (fateId );
406
406
}
407
407
408
- mutator .submit (needsNoUpdate ::test , () -> "cleanup metadata for failed compaction" );
408
+ mutator .submit (needsNoUpdate ::test ,
409
+ () -> "cleanup metadata for failed compaction. " + fateId );
409
410
}
410
411
}
411
412
}
0 commit comments