Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -334,11 +334,6 @@ public ClientContext(ClientInfo info, AccumuloConfiguration serverConf,
});

zkLockChecker = memoize(() -> {
// make this use its own ZooSession and ZooCache, because this is used by the
// tablet location cache, which is a static singleton reused by multiple clients
// so, it can't rely on being able to continue to use the same client's ZooCache,
// because that client could be closed, and its ZooSession also closed
// this needs to be fixed; TODO https://github.com/apache/accumulo/issues/2301
var zk = info.getZooKeeperSupplier(ZookeeperLockChecker.class.getSimpleName(),
ZooUtil.getRoot(getInstanceID())).get();
return new ZookeeperLockChecker(new ZooCache(zk, Set.of(Constants.ZTSERVERS)));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import java.util.stream.Collectors;

import org.apache.accumulo.core.data.TabletId;
import org.apache.accumulo.core.dataImpl.KeyExtent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

Expand Down Expand Up @@ -77,13 +78,12 @@ public void setMigrations(Set<TabletId> migrations) {
@Override
public void report() {
log.warn("Not balancing due to {} outstanding migrations.", migrations.size());
/*
* TODO ACCUMULO-2938 redact key extents in this output to avoid leaking protected
* information.
*/
if (log.isDebugEnabled()) {
// convert each tabletId in migrations to keyExtent for redacting
log.debug("Sample up to 10 outstanding migrations: {}",
migrations.stream().limit(10).map(String::valueOf).collect(Collectors.joining(", ")));
migrations.stream().limit(10)
.map(tabletId -> KeyExtent.fromTabletId(tabletId).obscured())
.collect(Collectors.joining(", ")));
}
// Now that we've reported, clear out the migrations list so we don't hold it in memory.
migrations = Collections.emptySet();
Expand Down