Skip to content

Commit 22552e1

Browse files
committed
formatting
1 parent 3929a0b commit 22552e1

File tree

5 files changed

+9
-9
lines changed

5 files changed

+9
-9
lines changed

server/manager/src/main/java/org/apache/accumulo/manager/compaction/coordinator/commit/CommitCompaction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ private TabletMetadata commitCompaction(ServerContext ctx, ExternalCompactionId
130130

131131
tabletMutator.submit(
132132
tabletMetadata -> !tabletMetadata.getExternalCompactions().containsKey(ecid),
133-
() -> "commit compaction "+ecid);
133+
() -> "commit compaction " + ecid);
134134

135135
if (LOG.isDebugEnabled()) {
136136
LOG.debug("Compaction completed {} added {} removed {}", tablet.getExtent(), newDatafile,

server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/CleanUpBulkImport.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ private static void removeBulkLoadEntries(Ample ample, TableId tableId, FateId f
111111
tabletsMutator.mutateTablet(tablet.getExtent()).requireAbsentOperation();
112112
tablet.getLoaded().entrySet().stream().filter(entry -> entry.getValue().equals(fateId))
113113
.map(Map.Entry::getKey).forEach(tabletMutator::deleteBulkFile);
114-
tabletMutator.submit(tm -> false, () -> "remove bulk load entries "+fateId);
114+
tabletMutator.submit(tm -> false, () -> "remove bulk load entries " + fateId);
115115
}
116116
}
117117

server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/LoadFiles.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -251,7 +251,7 @@ void load(List<TabletMetadata> tablets, Files files) {
251251
Preconditions.checkState(
252252
loadingFiles.put(tablet.getExtent(), List.copyOf(filesToLoad.keySet())) == null);
253253

254-
tabletMutator.submit(tm -> false, () -> "bulk load files "+fateId);
254+
tabletMutator.submit(tm -> false, () -> "bulk load files " + fateId);
255255
}
256256
}
257257

server/manager/src/main/java/org/apache/accumulo/manager/tableOps/delete/ReserveTablets.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,8 @@ public long isReady(FateId fateId, Manager manager) throws Exception {
9696
// must wait for the tablet to have no location before proceeding to actually delete. See
9797
// the documentation about the opid column in the MetadataSchema class for more details.
9898
conditionalMutator.mutateTablet(tabletMeta.getExtent()).requireAbsentOperation()
99-
.putOperation(opid).submit(tm -> opid.equals(tm.getOperationId()), () -> "put opid "+opid);
99+
.putOperation(opid)
100+
.submit(tm -> opid.equals(tm.getOperationId()), () -> "put opid " + opid);
100101
submitted++;
101102
}
102103
}

server/manager/src/main/java/org/apache/accumulo/manager/tableOps/merge/DeleteRows.java

+4-5
Original file line numberDiff line numberDiff line change
@@ -188,11 +188,10 @@ private Optional<KeyExtent> deleteTabletFiles(Manager manager, FateId fateId) {
188188
tabletMutator.putFile(file, dfv);
189189
});
190190

191-
tabletMutator
192-
.submit(
193-
tm -> tm.getFiles().containsAll(filesToAddMap.keySet())
194-
&& Collections.disjoint(tm.getFiles(), filesToDelete),
195-
() -> "delete tablet files (as part of merge or deleterow operation) "+fateId);
191+
tabletMutator.submit(
192+
tm -> tm.getFiles().containsAll(filesToAddMap.keySet())
193+
&& Collections.disjoint(tm.getFiles(), filesToDelete),
194+
() -> "delete tablet files (as part of merge or deleterow operation) " + fateId);
196195
}
197196

198197
var results = tabletsMutator.process();

0 commit comments

Comments
 (0)